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> {@Overridepublic 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()不能抛出受检查的异常。
转自:/andycpp/article/details/8902655