zoukankan      html  css  js  c++  java
  • 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

  • 相关阅读:
    Yii隐藏单入口
    JS字符串的问题
    暑假第三测
    暑假第二测
    暑假第一测
    沈阳集训day4
    沈阳集训day3
    P2571 [SCOI2010]传送带
    CF626C Block Towers
    洛谷P4171 [JSOI2010]满汉全席
  • 原文地址:https://www.cnblogs.com/hunterCecil/p/6076554.html
Copyright © 2011-2022 走看看