Java学习笔记（多线程）：CompetableFuture

csdn推荐

本文是自己的学习笔记，主要参考资料如下

JavaSE文档

1、Overview

CompletableFuture可以处理任务的执行顺序，比如A执行结束后再开始B，或者A和B同时进行，两者都结束后再开始C。

2、重要参数

CompletableFuture中有三个重要参数，他们的作用和Thread中的run方法一样，用来定义线程的行为。

他们的不同点知识入参和返回结果的不同。

比如我们写一个线程任务，参数是Supplier，那就不能传参，但是有返回值，就像callable()方法一样。

CompletableFuture<String> a = CompletableFuture.supplyAsync(() -> {
    System.out.println("第一个异步任务开始执行");
    System.out.println("第一个异步任务执行结束");
    return "supply example";
});
System.out.println(a.join());
Thread.sleep(5000L);

返回结果

3、主要方法 3.1、创建实例，获取返回值

一般用静态方法创建实例，有下面两种创建实例的方法，区别是是否有返回值。

这里以supplyAsync为例

public static void supplysync() throws Exception{
        // 不指定线程池，默认用ForkJoinPool，这个线程池的线程都是守护线程
        CompletableFuture<Void> result = CompletableFuture.supplyAsync(() -> {
            System.out.println("异步任务开始执行");
            System.out.println("异步任务执行结束");
            return "返回执行结果";
        })；
        System.out.println(result.join());
        // get()和join()一样，但是join()自己处理了异常，get()需要处理异常
        System.out.println(result.get());
        Thread.sleep(20000L);
    }

要注意，supplyAsync()和runAsync()都两个重载方法，即是否传入线程池。

public static <U> CompletableFuture<U> supplyAsync(Supplier<U> supplier);
public static <U> CompletableFuture<U> supplyAsync(Supplier<U> supplier, Executor executor);

如果不传入线程池，那默认使用ForkJoinPool作为线程池处理线程，而这个线程池的线程全是守护线程，所以测试代码中必须让主线程沉睡一会，免得主线程过早结束导致守护线程跟着结束让我们看不到测试结果。

3.2、线程执行顺序相关

CompletableFuture提供了下面几种控制线程执行顺序的方法，他们各自都有多个重载方法，这里不一一列举了。

下面两条规则比较普遍。

public static void thenSupply() throws Exception{
    CompletableFuture<String> a = CompletableFuture.supplyAsync(() -> {
        System.out.println("第一个异步任务开始执行");
        System.out.println("第一个异步任务执行结束");
        return "supply example";
    }).thenApply(b -> {
        System.out.println("第二个异步任务开始执行");
        System.out.println("第二个异步任务执行结束");
        return "thenApply example";
    });
    System.out.println(a.join());
    Thread.sleep(5000L);
}

文章来源:https://blog.csdn.net/sinat_38393872/article/details/139903658