前身 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资源
优点
- 回调通知执行结果,不会阻塞
- 异步执行
- 可以组合处理多个任务
- 对计算速度进行选用)
- 当不传线程池参数时则自动调用ForkJoinPool线程池。
whenComplete回调方法
- 当执行结束后自动执行该方法的代码,无需阻塞
- 参数为BiConsumer<T,E> 代表两个参数无返回值,T代表上一步返回的值,E代表抛出的异常
get和join的区别
thenApply和handle(对计算结果进行处理)
相同点
- 计算结果存在依赖关系,串行化执行,需要上一个返回值来当成参数
不同点
- 当thenApply中出现异常时后续不再执行
- 当handler中出现异常时,后续不会受到影响,继续执行
thenAccept(计算结果病并消费、无返回结果)
thenRun、thenAccept、thenApply对比
thenRun和thenRunAsync区别(线程池运行选择)
applyToEither(对计算速度进行选用、谁快用谁)
thenCombine(对计算结果进行合并)
- 两个CompletionStage任务都完成后、最终能把两个任务的结果一起交给thenCombine来处理