javaThreadPoolExecutor并发调用实例详解-创新互联
java ThreadPoolExecutor 并发调用实例详解
概述
通常为了提供任务的处理速度,会使用一些并发模型,ThreadPoolExecutor中的invokeAll便是一种。
代码
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>> tasks = new ArrayList<>(); for (int i = 0; i < 10; i++) { Callable > task = new Callable
>() { @Override public List
call() throws Exception { return Arrays.asList(1L,2L); } }; tasks.add(task); } List finalResults = new ArrayList<>(10); List >> results = ThreadPool.getThreadPool().invokeAll(tasks); for(Future > ele : results) { List
list = ele.get(); finalResults.addAll(list); } System.out.println(finalResults); } }
分享题目:javaThreadPoolExecutor并发调用实例详解-创新互联
链接URL:http://jxruijie.cn/article/ddiiho.html