Java的Future接口

　　Java的Future接口
　　Java中的Future接口和其实现类FutureTask，代表了异步计算的结果。1。Future接口简介
　　Future是异步计算结果的容器接口，它提供了下面这些功能：在等待异步计算完成时检查计算结果是否完成在异步计算完成后获取计算结果在异步计算完成前取消
　　Future可以用于耗时的异步计算任务。例如我们把Runnable接口或Callable接口的实现类提交到线程池时，线程池会返回一个FutureTask对象。TFutureTsubmit（CallableTtask）TFutureTsubmit（RunnableTtask，Tresult）
　　下文会再解释FutureTask，这是Future接口的一个实现类。Future接口提供了下面这些方法
　　ModifierandType
　　Method
　　Description
　　boolean
　　cancel（booleanmayInterruptIfRunning）
　　尝试取消执行此任务。
　　V
　　get（）
　　等待计算完成，然后检索其结果。
　　V
　　get（longtimeout，TimeUnitunit）
　　如果需要等待最多在给定的时间计算完成，然后检索其结果（如果可用）。
　　boolean
　　isCancelled（）
　　如果此任务在正常完成之前被取消，则返回true。
　　boolean
　　isDone（）
　　返回true如果任务已完成。2。FutureTask的使用
　　可以将FutureTask交给Executor执行，也可以通过ExecutorService。submit（。。。）方法返回一个FutureTask，然后执行get方法或cancel方法。
　　也可以单独使用FutureTask，比如下面的代码就实现了一种需求：一个线程必须等待另一个线程把某个任务执行完后它才能继续执行。假设有多个线程执行若干个任务，每个任务最多只能同时被执行一次，多个线程试图执行同一个任务时，只允许一个线程执行任务，其他线程等待这个任务执行完后才能继续执行。publicclassConcurrentTask｛privatefinalConcurrentMapObject，FutureStringtaskCachenewConcurrentHashMapObject，FutureString（）；privateStringexecutionTask（finalStringtaskName）throwsExecutionException，InterruptedException｛while（true）｛FutureStringfuturetaskCache。get（taskName）；1。1，2。1if（futurenull）｛创建TaskCallableStringtasknewCallableString（）｛publicStringcall（）throwsInterruptedException｛。。。。。。returntaskName；｝｝；1。2创建FutureTaskFutureTaskStringfutureTasknewFutureTask（task）；futuretaskCache。putIfAbsent（taskName，futureTask）；1。3如果是第一次放入，则尝试执行if（futurenull）｛futurefutureTask；futureTask。run（）；1。4执行任务｝｝try｛returnfuture。get（）；1。5，2。2线程在此等待任务执行完成｝catch（CancellationExceptione）｛taskCache。remove（taskName，future）；｝｝｝｝
　　相信不难理解，下面是执行的示意图。
　　3。FutureTask的实现
　　FutureTask的实现基于队列同步器QAS。
　　基于复合优先于继承的原则，FutureTask声明了一个内部私有的，继承于AQS的子类Sync，这对FutureTask所有公有方法的调用都会委托给这个内部子类。
　　FutureTask的get方法会调用AQS。acquireSharedInterruptibly（intarg）方法，执行过程如下：调用AQS。acquireSharedInterruptibly（intarg）方法，首先回调子类Sync中的方法tryAcqurieShared判断acquire操作是否可以成功。acquire操作成功的条件为：state为执行完成状态RAN或已取消状态CANCELLED且runner不为null。如果成功则get方法立即返回，失败则到线程等待队列中去等待其他线程执行release。当其他线程执行release，如FutureTask。run（）和FutureTask。cancel（），唤醒当前线程后。当前线程再次执行tryAcquireShared将返回值1，当前线程离开等待队列并唤醒后续线程。最后返回结果或抛出异常。
　　FutureTask的run方法执行过程如下：执行构造函数中指定的任务。原子方式更新同步状态，调用AQS。compareAndSetState如果上面的原子操作成功，设置代表计算结果的变量result的值为Callable。call（）的返回指，然后调用AQS。releaseShared（intarg）AQS。releaseShared（intarg）首先回调Sync中的tryReleaseShared（arg）来执行release。这个方法唤醒等待队列中第一个线程。调用FutureTask。done（）。
　　当调用FutureTask。get（）方法时，如果FutureTask不是处于执行完成状态RAN或已取消状态CANCELLED。当前执行线程将到AQS的线程等待队列中等待。
　　收藏