CompletableFuture的runAfterBothAsync

简介: CompletableFuture的runAfterBothAsyncrunAfterBothAsync:假设有两个线程A和B,这两个线程都是异步执行的,但是不确定A和B何时执行完毕,但是需要在A和B都执行完毕后运行线程C。

CompletableFuture的runAfterBothAsync


runAfterBothAsync:假设有两个线程A和B,这两个线程都是异步执行的,但是不确定A和B何时执行完毕,但是需要在A和B都执行完毕后运行线程C。

    private void test() {

        System.out.println("开始...");

        CompletableFuture.supplyAsync(new Supplier<String>() {
            @Override
            public String get() {
                try {
                    TimeUnit.SECONDS.sleep(3);
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }

                System.out.println("返回 zhang");
                return "zhang";
            }
        }).runAfterBothAsync(CompletableFuture.supplyAsync(new Supplier<String>() {
            @Override
            public String get() {
                try {
                    TimeUnit.SECONDS.sleep(5);
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }

                System.out.println("返回 phil");
                return "phil";
            }
        }), new Runnable() {
            @Override
            public void run() {
                System.out.println("开始 run");
            }
        });
    }



代码运行结果输出:

07-02 14:06:59.016 23450-23450/zhangphil.test I/System.out: 开始...
07-02 14:07:02.020 23450-23493/zhangphil.test I/System.out: 返回 zhang
07-02 14:07:04.021 23450-23494/zhangphil.test I/System.out: 返回 phil
    开始 run


线程返回“zhang”和"phil"后, 开始运行线程Runnable里面的线程体。注意返回“zhang”和“phil”的线程是同时执行的。

相关文章
|
6月前
|
缓存 Java Maven
CompletableFuture
【7月更文挑战第29天】
60 4
|
6月前
|
Java 开发者 Spring
CompletableFuture 使用总结
CompletableFuture 使用总结
190 1
|
5月前
|
Java 测试技术
CompletableFuture 使用
CompletableFuture 使用
68 0
|
5月前
CompletableFuture 打桌球的应用
CompletableFuture 打桌球的应用
24 0
|
6月前
|
存储 缓存 安全
(八)深入并发之Runnable、Callable、FutureTask及CompletableFuture原理分析
关于Runnable、Callable接口大家可能在最开始学习Java多线程编程时,都曾学习过一个概念:在Java中创建多线程的方式有三种:继承Thread类、实现Runnable接口以及实现Callable接口。但是实则不然,真正创建多线程的方式只有一种:继承Thread类,因为只有`new Thread().start()`这种方式才能真正的映射一条OS的内核线程执行,而关于实现Runnable接口以及实现Callable接口创建出的Runnable、Callable对象在我看来只能姑且被称为“多线程任务”,因为无论是Runnable对象还是Callable对象,最终执行都要交由Threa
139 1
|
8月前
|
Java API
java多线程之FutureTask、Future、CompletableFuture
java多线程之FutureTask、Future、CompletableFuture
378 0
|
Java
CompletableFuture总结和实践
CompletableFuture被设计在Java中进行异步编程。异步编程意味着在主线程之外创建一个独立的线程,与主线程分隔开,并在上面运行一个非阻塞的任务,然后通知主线程进展,成功或者失败。
389 0
|
消息中间件 Java 中间件
Future and CompletableFuture
Future代表异步执行的结果,也就是说异步执行完毕后,结果保存在Future里, 我们在使用线程池submit()时需要传入Callable接口,线程池的返回值为一个Future,而Future则保存了执行的结果 ,可通过Future的get()方法取出结果,如果线程池使用的是execute(),则传入的是Runnable接口 无返回值。
87 0
|
Java 调度
并发编程——Future & CompletableFuture
Java创建线程的方式,一般常用的是Thread,Runnable。如果需要当前处理的任务有返回结果的话,需要使用Callable。Callable运行需要配合Future。
71 0