Future

Future接口由FutureTask 实现类定义了操作异步任务执行的一些方法,比如异步任务的执行结果、取消任务的执行、判断任务是否被取消、判断任务执行是否完毕等。Future 接口可以为主线程开一个分支任务,专门为主线程处理耗时和费力的业务。

Future是java5新加的一个借口,提供了一种异步并行计算的功能。
目的异步多线程任务执行且返回有结果
三个特点多线程/有返回/异步任务

runable 实现run方法 没有返回值 无异常
callable 实现call方法 有返回值 有异常

多线程只能接受Runable,RunableFuture同时满足了线程和异步
FutureTask 这个类支持构造注入,满足三个要求多线程/有返回/异步任务

FutureTask 继承实现关系图
在这里插入图片描述

futuretask demo

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
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 对于结果的获取不是很友好,只能通过阻塞或者轮询的方式

作者声明

1
如有问题,欢迎指正!