JUC学习系列十（异步计算 FutureTask）

2019年3月10日 248次阅读来源: JUC

public interface Future<V>
Future 表示异步计算的结果。它提供了检查计算是否完成的方法，以等待计算的完成，并获取计算的结果。计算完成后只能使用 get 方法来获取结果，如有必要，计算完成前可以阻塞此方法。取消则由 cancel 方法来执行。还提供了其他方法，以确定任务是正常完成还是被取消了。一旦计算完成，就不能再取消计算。如果为了可取消性而使用 Future 但又不提供可用的结果，则可以声明 Future<?> 形式类型、并返回 null 作为底层任务的结果。

Future接口的族谱结构：

《JUC学习系列十（异步计算 FutureTask）》

FutureTask的介绍和使用：

可取消的异步计算。利用开始和取消计算的方法、查询计算是否完成的方法和获取计算结果的方法，此类提供了对 Future 的基本实现。仅在计算完成时才能获取结果；如果计算尚未完成，则阻塞 get 方法。一旦计算完成，就不能再重新开始或取消计算。可使用 FutureTask 包装 Callable 或 Runnable 对象。因为 FutureTask 实现了 Runnable，所以可将 FutureTask 提交给 Executor 执行。除了作为一个独立的类外，此类还提供了 protected 功能，这在创建自定义任务类时可能很有用。

使用案例：

public class FutureTest {

    public static void main(String[] args) {
        //方式一  FutureTask(Callable<V> callable)
        Callable<Integer> call=new Callable<Integer>() {
            @Override
            public Integer call() throws Exception {
                System.out.println("正在处理计算结果...");
                TimeUnit.SECONDS.sleep(1);
                return 27;
            }
        };
        //方式二   FutureTask(Runnable runnable, V result)
        Runnable run=new Runnable() {
            @Override
            public void run() {
                try {
                    TimeUnit.SECONDS.sleep(1);
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
                System.out.println("处理完毕...");
            }
        };
//        FutureTask<Integer> task=new FutureTask<Integer>(call);  //方式一
        FutureTask<Integer> task=new FutureTask<Integer>(run,27);//方式二
        new Thread(task).start();

        System.out.println("其他的任务处理中...");
        try {
            Integer result=task.get();
            System.out.println("获得计算结果"+result);
        } catch (Exception e) {
            e.printStackTrace();
        }
    }

}

案例执行结果：

《JUC学习系列十（异步计算 FutureTask）》