新聞中心
這里有您想知道的互聯(lián)網營銷解決方案
javaThreadPoolExecutor并發(fā)調用實例詳解-創(chuàng)新互聯(lián)
java ThreadPoolExecutor 并發(fā)調用實例詳解
概述
通常為了提供任務的處理速度,會使用一些并發(fā)模型,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并發(fā)調用實例詳解-創(chuàng)新互聯(lián)
網站路徑:http://www.dlmjj.cn/article/ddiiho.html