Future
Future接口由FutureTask 实现类定义了操作异步任务执行的一些方法,比如异步任务的执行结果、取消任务的执行、判断任务是否被取消、判断任务执行是否完毕等。Future 接口可以为主线程开一个分支任务,专门为主线程处理耗时和费力的业务。
Future是java5新加的一个借口,提供了一种异步并行计算的功能。
目的异步多线程任务执行且返回有结果
三个特点多线程/有返回/异步任务
runable 实现run方法 没有返回值 无异常
callable 实现call方法 有返回值 有异常
多线程只能接受Runable,RunableFuture同时满足了线程和异步
FutureTask 这个类支持构造注入,满足三个要求多线程/有返回/异步任务
FutureTask 继承实现关系图
futuretask demo
package com.jhj.Thread.future;
import java.util.concurrent.Callable;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.FutureTask;
public class CompletableFutureDemo {
public static void main(String[] args) throws ExecutionException, InterruptedException {
//异步多线程
FutureTask futureTask = new FutureTask(new MyThread2());
Thread t1 = new Thread(futureTask, "t1");
t1.start();
//获取返回值
System.out.println(futureTask.get());
}
}
class MyThread implements Runnable{
@Override
public void run() {
}
}
class MyThread2 implements Callable<String>{
@Override
public String call() throws Exception {
System.out.println("come");
return "hello";
}
}
- future+线程池异步多线程任务配合,可以显著提高程序的执行效率。
- 缺点 一旦调用get 就需要等到返回结果再往下执行 程序阻塞 可以通过 stringFutureTask.get(3,TimeUnit.SECONDS);设置等待时间实现过期不候,减少阻塞但是回抛出超时异常
- 根据isDone() 状态判断,但是需要不停的轮询,会耗费很多资源
结论
Future 对于结果的获取不是很友好,只能通过阻塞或者轮询的方式
作者声明
如有问题,欢迎指正!