CompletableFuture使用

CompletableFuture

# CompletableFuture

CompletableFuture实现了CompletionStage接口和Future接口（见源码），前者是对后者的一个扩展，增加了异步回调、流式处理、多个Future组合处理的能力，使Java在处理多任务的协同工作时更加顺畅便利。

@Test
public void test4() throws Exception {
        ExecutorService executorService= Executors.newSingleThreadExecutor(); // 创建线程池
        // 创建异步执行任务:
        CompletableFuture cf = CompletableFuture.runAsync(()->{
            System.out.println(Thread.currentThread()+" start,time->"+System.currentTimeMillis());
            try {
                Thread.sleep(2000);
            } catch (InterruptedException e) {
            }
            if(false){
                throw new RuntimeException("test");
            }else{
                System.out.println(Thread.currentThread()+" exit,time->"+System.currentTimeMillis());
            }
        },executorService);
        System.out.println("main thread start,time->"+System.currentTimeMillis());
        //等待子任务执行完成
        System.out.println("run result->"+cf.get());
        System.out.println("main thread exit,time->"+System.currentTimeMillis());
}

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21

如果不传线程池，默认使用ForkJoinPool.commonPool()，如果机器是单核的，则默认使用ThreadPerTaskExecutor，该类是一个内部类，每次执行execute都会创建一个新线程

参考文章：

图文解析 CompletableFuture，_ITMuch的专栏-CSDN博客 (opens new window)

Java8 CompletableFuture 用法全解_菜鸟进阶之路-CSDN博客_completablefuture (opens new window)

← lambda使用及其技巧 lombok的使用及技巧→