为什么要用Future

我们在并发编程时，经常会使用两种创建线程的方法：

• 继承Thread类
• 实现Runnable接口

但是这两种方法都缺少我们经常会遇到的一种需求----获取线程执行结果。

比如我们要进行两个运算，然后把两个运算的和返回。当然我们可以使用串联执行两个运算，然后再将两个结果求和返回。但是如果我们但运算特别复杂，耗时较多，我们需要统筹时间，让两个运算一起执行，处理器多个核心分别处理一个运算，这样会极大降低处理时间。使用Thread和Runnable都无法获取执行结果，这时候我们就需要用到Future了。

JDK1.5开始，就提供了Callable和Future。Future模式的核心思想能够让主线程将原来需要同步等待的这段时间用来做其他的事情。让主线程不必等待任务完成，而是过段时间来获取执行结果。

Future接口

CompetableFuture和ForkJoinFuture两个类实现了Future接口，RunnableFuture和SchedualedFuture两个接口继承了Future接口

1. RunnableFuture
   这个接口同时继承Future接口和Runnable接口，在成功执行run()方法后，可以通过Future访问执行结果。这个接口都实现类是FutureTask,一个可取消的异步计算，这个类提供了Future的基本实现。FutureTask能用来包装一个Callable或Runnable对象，因为它实现了Runnable接口，而且它能被传递到Executor进行执行。为了提供单例类，这个类在创建自定义的工作类时提供了protected构造函数。
2. SchedualedFuture
   这个接口表示一个延时的行为可以被取消。通常一个安排好的future是定时任务SchedualedExecutorService的结果
3. CompleteFuture
   一个Future类是显示的完成，而且能被用作一个完成等级，通过它的完成触发支持的依赖函数和行为。当两个或多个线程要执行完成或取消操作时，只有一个能够成功。
4. ForkJoinTask
   基于任务的抽象类，可以通过ForkJoinPool来执行。一个ForkJoinTask是类似于线程实体，但是相对于线程实体是轻量级的。大量的任务和子任务会被ForkJoinPool池中的真实线程挂起来，以某些使用限制为代价。

Future主要方法

• get()
  当任务结束后返回一个结果，如果调用时，工作还没有结束，则会阻塞线程，直到任务执行完毕。

• get(long timeout,TimeUnit unit)
  可以允许在一定时间内去等待获取执行结果，如果超过这个时间，抛出TimeoutException。
• cancel(boolean mayInterruptIfRunning)
  我们可以取消这个执行逻辑，如果这个逻辑已经正在执行，提供可选的参数来控制是否取消已经正在执行的逻辑。调用cancel并不是一定可以停止执行。
• isDone()
  我们可以判断执行逻辑是否已经执行完成。
• isCancel()
  我们可以判断执行逻辑是否已经被取消。

閱讀更多 evilRat 的文章

關鍵字: Runnable 接口 运算