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); } }
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; } }
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!