Example code analysis of concurrent calls of ThreadPoolExecutor in java-javaTutorial-php.cn

Home

Java

javaTutorial

Example code analysis of concurrent calls of ThreadPoolExecutor in java

May 28, 2017 am 09:11 AM

This article mainly introduces the relevant information about the detailed explanation of the java ThreadPoolExecutor concurrent call instance. Friends who need it can refer to

java ThreadPoolExecutor detailed explanation of the concurrent call instance

Overview

Usually in order to provide task processing speed, some concurrency models are used. InvokeAll in ThreadPoolExecutor is one .

Code

package test.current;

import java.util.ArrayList;
import java.util.Arrays;
import java.util.List;
import java.util.concurrent.Callable;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.Future;

public class TestCallable {

  public static void main(String[] args) throws InterruptedException, ExecutionException {

    List&lt;Callable&lt;List&lt;Long&gt;&gt;&gt; tasks = new ArrayList&lt;&gt;();
    for (int i = 0; i &lt; 10; i++) {
      Callable&lt;List&lt;Long&gt;&gt; task = new Callable&lt;List&lt;Long&gt;&gt;() {
        @Override
        public List&lt;Long&gt; call() throws Exception {
          return Arrays.asList(1L,2L);
        }
      };

      tasks.add(task);
    }

    List&lt;Long&gt; finalResults = new ArrayList&lt;&gt;(10);
    List&lt;Future&lt;List&lt;Long&gt;&gt;&gt; results = ThreadPool.getThreadPool().invokeAll(tasks);
    for(Future&lt;List&lt;Long&gt;&gt; ele : results) {
      List&lt;Long&gt; list = ele.get();
      finalResults.addAll(list);
    }

    System.out.println(finalResults);
  }
}

Copy after login

package test.current;

import java.util.concurrent.ArrayBlockingQueue;
import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit;

public class ThreadPool {
  private static final int CORE_SIZE = 8;

  private static final int MAX_SIZE = 12;

  private static final long KEEP_ALIVE_TIME = 30;

  private static final int QUEUE_SIZE = 50000;

  private static ThreadPoolExecutor threadPool = new ThreadPoolExecutor(CORE_SIZE, MAX_SIZE, KEEP_ALIVE_TIME,
      TimeUnit.SECONDS, new ArrayBlockingQueue&lt;Runnable&gt;(QUEUE_SIZE), new ThreadPoolExecutor.AbortPolicy());

  public static ThreadPoolExecutor getThreadPool() {
    return threadPool;
  }
}

Copy after login

You can create a Callable task for the tasks that need to be executed, and use the threads in the thread pool to execute these tasks concurrently, thereby improving the execution efficiency of the task.

The above is the detailed content of Example code analysis of concurrent calls of ThreadPoolExecutor in java. For more information, please follow other related articles on the PHP Chinese website!

Statement of this Website

The content of this article is voluntarily contributed by netizens, and the copyright belongs to the original author. This site does not assume corresponding legal responsibility. If you find any content suspected of plagiarism or infringement, please contact admin@php.cn