From 1a3c7ef5d24ad1e7e09b98aa81aa42aac18cbfd2 Mon Sep 17 00:00:00 2001 From: xiangwb Date: Sat, 10 Feb 2018 16:16:22 +0800 Subject: [PATCH] merge --- boot-service/src/main/java/com/xwbing/demo/LambdaDemo.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/boot-service/src/main/java/com/xwbing/demo/LambdaDemo.java b/boot-service/src/main/java/com/xwbing/demo/LambdaDemo.java index cc800a7..092f39d 100644 --- a/boot-service/src/main/java/com/xwbing/demo/LambdaDemo.java +++ b/boot-service/src/main/java/com/xwbing/demo/LambdaDemo.java @@ -101,7 +101,7 @@ public class LambdaDemo { finalList.add(null);//必须有这步,否则会下标越界 Integer integer = list.get(i); final int pos = i; - futures[i] = CompletableFuture.supplyAsync(() -> finalList.set(pos, integer));//按原来顺序存 + futures[i] = CompletableFuture.supplyAsync(() -> finalList.set(pos, integer),taskExecutor);//按原来顺序存 } CompletableFuture.allOf(futures).join();//线程等待,效果等同于get(),会拋出CompletionException // CompletableFuture completableFuture = CompletableFuture.allOf(futures);