callable 和 FutureTask 和 future以及浅谈completionService

callable 和 FutureTask

callable能够返回运行结果,经过FutureTask去接收这个结果。使用方法为

FutureTask task = new FutureTask(new Callable)；

new Thread(task).start();

去拿callable的返回值时，调用task.get()方法调用，若是call方法尚未执行结束，该线程就会被阻塞住，因此最好设置一个超时时间。

另外值得一提的是，futuretask能够覆盖一个done方法，当call方法执行结束以后，会自动调用done方法。详细demo以下：

public static void main(String[] args) throws Exception {
//        ExecutorService service = Executors.newCachedThreadPool();
        Callable<String> callable = new Callable<String>() {
            @Override
            public String call() throws Exception {
                System.out.println("执行callable方法");
                Thread.sleep(5000);
                return "执行成功";
            }
        };
        MyFuture future = new MyFuture(callable);
        new Thread(future).start();
        System.out.println("拿到返回值是：" + future.get());
    }
    public static  class MyFuture extends FutureTask {
        public MyFuture(Callable callable) {
            super(callable);
        }
        @Override
        protected void done() {
            System.out.println("callable方法执行成功，我这个done方法被触发了");
        }
    }

执行结果以下：

Future和Callable

public static void main(String[] args) throws Exception {
        ExecutorService service = Executors.newCachedThreadPool();
        Callable<String> callable = new Callable<String>() {
            @Override
            public String call() throws Exception {
                System.out.println("执行callable方法");
                Thread.sleep(5000);
                return "执行成功";
            }
        };
        Future future = service.submit(callable);
        System.out.println("拿到返回值是：" + future.get());
    }

执行结果:

CompletionService（生产者消费者模式）

    日常咱们要拿到一组线程池的处理结果，有一种方法是定义一个List<Future>，而后将每一个任务处理的Future加入到这个list里面，而后循环这个List里的每一个Future去future.get()，可是这样作有个很差的地方在于，假如我此次future正好是处理最后一个才结束，这期间内其余的任务都已经处理结束了，可是因为这个没结束，我一直被阻塞住。而这时候能够利用CompletionService，利用这个类，能够依次拿到最新处理结束的任务。实现的原理是经过FutureTask，FutureTask能够在任务执行完毕以后处理done方法，而后CompletionService会建立一个队列，当每一个futuretask处理完毕，将结果放入这个对列，而后service一直在take，当队列里有结果的时候就拿走一个（简直就是生产者消费者模式）