JUC之 completableFuture

前身 Future

作用

  • 定义了操作异步任务执行的一些方法,如获取异步任务的执行结果、取消任务的执行、判断任务执行是否完毕等。专门用来为主线程处理耗时的任务

特点

  • 多线程
  • 有返回值
  • 异步处理

实现类FutureTask

在这里插入图片描述

代码示例

public class FutureThread {

    public static void main(String[] args) throws ExecutionException, InterruptedException {
        FutureTask<String> futureTask = new FutureTask<>(new mythread2());

        Thread t1 = new Thread(futureTask,"t1");
t1.start();
        String s = futureTask.get();
        System.out.println(s);
    }


}



class mythread2 implements Callable<String>{

    @Override
    public String call() throws Exception {
        System.out.println("come in deep dark fantasy!");


        return "callable的返回值捏";
    }
}

缺点

  • get方法获取值直到线程结束才会继续向下执行,容易阻塞
  • isDone不断轮询会消耗cpu资源

CompletableFuture

优点

  • 回调通知执行结果,不会阻塞
  • 异步执行
  • 可以组合处理多个任务
  • 对计算速度进行选用)

调用静态方法初始化

- CompletableFuture.runAsync(Run)

  • 当不传线程池参数时则自动调用ForkJoinPool线程池。

whenComplete回调方法

  • 当执行结束后自动执行该方法的代码,无需阻塞
  • 参数为BiConsumer<T,E> 代表两个参数无返回值,T代表上一步返回的值,E代表抛出的异常

    在这里插入图片描述

get和join的区别

  • 二者的作用相同,都是获取CompletableFuture的返回值,但是get需要处理检查型异常,也就是必须抛出或者处理,而join则不用处理。

thenApply和handle(对计算结果进行处理)

相同点

  • 计算结果存在依赖关系,串行化执行,需要上一个返回值来当成参数

    在这里插入图片描述

不同点

  • 当thenApply中出现异常时后续不再执行
  • 当handler中出现异常时,后续不会受到影响,继续执行

    在这里插入图片描述

thenAccept(计算结果病并消费、无返回结果)

在这里插入图片描述

thenRun、thenAccept、thenApply对比

在这里插入图片描述

thenRun和thenRunAsync区别(线程池运行选择)

在这里插入图片描述

applyToEither(对计算速度进行选用、谁快用谁)

在这里插入图片描述

thenCombine(对计算结果进行合并)

  • 两个CompletionStage任务都完成后、最终能把两个任务的结果一起交给thenCombine来处理

    在这里插入图片描述

相关文章

学习编程是顺着互联网的发展潮流,是一件好事。新手如何学习...
IT行业是什么工作做什么?IT行业的工作有:产品策划类、页面...
女生学Java好就业吗?女生适合学Java编程吗?目前有不少女生...
Can’t connect to local MySQL server through socket \'/v...
oracle基本命令 一、登录操作 1.管理员登录 # 管理员登录 ...
一、背景 因为项目中需要通北京网络,所以需要连vpn,但是服...