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
    
      callable = new Callable
     
      () {            @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
    
      callable = new Callable
     
      () {            @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，当队列里有结果的时候就拿走一个（简直就是生产者消费者模式）