1、概念
Future表示一个可能还没有完成的异步任务的结果,针对这个结果可以添加Callback以便在任务执行成功或失败后作出相应的操作。
2、Future接口
Future接口定义了主要的5个接口方法,有RunnableFuture和SchedualFuture继承这个接口,以及CompleteFuture和ForkJoinTask继承这个接口。
3、实例
package test; import ja***util.concurrent.Callable; import ja***util.concurrent.ExecutionException; import ja***util.concurrent.FutureTask; public class CallableFutureTest { public static void main(String[] args) { long startTime = Sy***m.currentTimeMillis(); CallablecalculateCallable = new Callable () { @Override public Integer call() throws Exception { // TODO Auto-generated method stub Th***d.sleep(2000);//模拟耗时时间 int result = 1+2; return result; } }; FutureTask calculateFutureTask = new FutureTask<>(calculateCallable); Thread t1 = new Thread(calculateFutureTask); t1.start(); //现在加入Thread运行的是一个模拟远程调用耗时的服务,并且依赖他的计算结果(比如网络计算器) try { //模拟耗时任务,主线程做自己的事情,体现多线程的优势 Th***d.sleep(3000); int a = 3+5; Integer result = ca***lateFutureTask.get(); Sy***m.out.println("result = "+(a+result));//模拟主线程依赖子线程的运行结果 long endTime = Sy***m.currentTimeMillis(); Sy***m.out.println("time = "+(endTime-startTime)+"ms"); } catch (InterruptedException | ExecutionException e) { // TODO Auto-generated catch block e.***ntStackTrace(); } } }
从上面可以看到上面耗时大概是3s,其实主要就是主线程sleep(3000)所耗费的时间,如果不使用Future,并且依赖线程的结果,我们可能需要的时间可能是需要5s(子线程2s+主线程3s)。
以上就是Future在java中获取线程结果的方法,可以说Future在处理线程上比较灵活,机制大致为进行一个线程时,另一个线程同时运行。大家感兴趣的话,可以在课后深入了解。
上一篇: java中内存模型是什么?有什么用?