FutureTask 用法

FutureTask应用场景：

如果不想分支线程阻塞主线程，又想取得分支线程的执行结果，就用FutureTask

 

 

    FutureTask简介：

FutureTask是一种可以取消的异步的计算任务。它的计算是通过Callable实现的，它等价于可以携带结果的Runnable，并且有三个状态：等待、运行和完成。完成包括所有计算以任意的方式结束，包括正常结束、取消和异常。

Future有个get方法而获取结果只有在计算完成时获取，否则会一直阻塞直到任务转入完成状态，然后会返回结果或者抛出异常。

Executor框架利用FutureTask来完成异步任务，并可以用来进行任何潜在的耗时的计算。一般FutureTask多用于耗时的计算，主线程可以在完成自己的任务后，再去获取结果。

FutureTask有下面几个重要的方法：

1.get() 阻塞一直等待执行完成拿到结果

2.get(int timeout, TimeUnit timeUnit) 阻塞一直等待执行完成拿到结果，如果在超时时间内，没有拿到抛出异常

3.isCancelled() 是否被取消

4.isDone() 是否已经完成

5.cancel(boolean mayInterruptIfRunning) 试图取消正在执行的任务

 

 

下面是网上找的FutureTask的示例：

 

 

public class CountNum implements Callable {

    private Integer sum;

    public CountNum(Integer sum) {
        this.sum = sum;
    }

    public Object call() throws Exception {
        for (int i = 0; i < 100; i++) {
            sum = sum + i;
        }
        // 休眠5秒钟，观察主线程行为，预期的结果是主线程会继续执行，到要取得FutureTask的结果是等待直至完成。
        Thread.sleep(3000);
        System.out.println("futureTask 执行完成" + System.currentTimeMillis());
        return sum;
    }

}

 

 

public class FutureTaskTest {

    /**
     * @param args
     */
    public static void main(String[] args) {
        CountNum cn = new CountNum(0);
        // FutureTask<Integer> 这里的表示返回的是Integer
        FutureTask<Integer> ft = new FutureTask<Integer>(cn);
        Thread td = new Thread(ft);
        System.out.println("futureTask开始执行计算:" + System.currentTimeMillis());
        td.start();
        System.out.println("main 主线程可以做些其他事情:" + System.currentTimeMillis());
        try {
            // futureTask的get方法会阻塞，知道可以取得结果为止
            Integer result = ft.get();
            System.out.println("计算的结果是:" + result);
        } catch (InterruptedException e) {
            e.printStackTrace();
        } catch (ExecutionException e) {
            e.printStackTrace();
        }
        System.out.println("取得分支线程执行的结果后，主线程可以继续处理其他事项");
    }

}