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