JAVA并发编程学习笔记------FutureTask

FutureTask是Future和Callable的结合体。传统的代码是这样写的
Future f = executor.submit(new Callable());

然后通过Future来取得计算结果。但是，若开启了多个任务，我们无从知晓哪个任务最先结束，因此，若要实现“当某任务结束时，立刻做一些事情，例如记录日志”这一功能，就需要写一些额外的代码。FutureTask正是为此而存在，他有一个回调函数protected void done()，当任务结束时，该回调函数会被触发。因此，只需重载该函数，即可实现在线程刚结束时就做一些事情。实例如下：

public class FutureTaskTest {
    public static void main(String[] args) {
        ExecutorService service = Executors.newCachedThreadPool();
        for(int i=0;i<10;i++){
            Callable<String> c = new Task();
            MyFutureTask ft = new MyFutureTask(c);
            service.submit(ft);
        }
    }

    static class MyFutureTask extends FutureTask<String>{
        public MyFutureTask(Callable<String> callable) {
            super(callable);
        }
        protected void done(){
            try {
                System.out.println(get());
            } catch (InterruptedException e) {
                e.printStackTrace();
            } catch (ExecutionException e) {
                e.printStackTrace();
            }
        }
    }

    static class Task implements Callable<String> {

        @Override
        public String call() throws Exception {
            TimeUnit.SECONDS.sleep(new Random().nextInt(12));
            return Thread.currentThread().getName();
        }
    }
}

注：
Callable 和 Runnable 的使用方法大同小异，区别在于：
1.Callable 使用 call（）方法， Runnable 使用 run() 方法
2.call() 可以返回值，而 run()方法不能返回。
3.call() 可以抛出受检查的异常，比如ClassNotFoundException，而run()不能抛出受检查的异常。

转自：http://blog.csdn.net/andycpp/article/details/8902655