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

Example code analysis of concurrent calls of ThreadPoolExecutor in java

黄舟

Release： 2017-05-28 09:11:13

Original

2086 people have browsed it

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<Callable<List<Long>>> tasks = new ArrayList<>();
    for (int i = 0; i < 10; i++) {
      Callable<List<Long>> task = new Callable<List<Long>>() {
        @Override
        public List<Long> call() throws Exception {
          return Arrays.asList(1L,2L);
        }
      };

      tasks.add(task);
    }

    List<Long> finalResults = new ArrayList<>(10);
    List<Future<List<Long>>> results = ThreadPool.getThreadPool().invokeAll(tasks);
    for(Future<List<Long>> ele : results) {
      List<Long> 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<Runnable>(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!