Java 多线程中关于 ExecutorService 和 CompletionService的讨论
2017-06-10 15:32
531 查看
我们现在在Java中使用多线程通常不会直接用Thread对象了,而是会用到java.util.concurrent包下的ExecutorService类来初始化一个线程池供我们使用。 之前我一直习惯自己维护一个list保存submit的callable task所返回的Future对象。
在主线程中遍历这个list并调用Future的get()方法取到Task的返回值。
但是,我在很多地方会看到一些代码通过CompletionService包装ExecutorService,然后调用其take()方法去取Future对象。
以前没研究过这两者之间的区别。今天看了源代码之后就明白了。
这两者最主要的区别在于submit的task不一定是按照加入自己维护的list顺序完成的。
从list中遍历的每个Future对象并不一定处于完成状态,这时调用get()方法就会被阻塞住,如果系统是设计成每个线程完成后就能根据其结果继续做后面的事,这样对于处于list后面的但是先完成的线程就会增加了额外的等待时间。
而CompletionService的实现是维护一个保存Future对象的BlockingQueue。只有当这个Future对象状态是结束的时候,才会加入到这个Queue中,take()方法其实就是Producer-Consumer中的Consumer。它会从Queue中取出Future对象,如果Queue是空的,就会阻塞在那里,直到有完成的Future对象加入到Queue中。
所以,先完成的必定先被取出。这样就减少了不必要的等待时间
在主线程中遍历这个list并调用Future的get()方法取到Task的返回值。
但是,我在很多地方会看到一些代码通过CompletionService包装ExecutorService,然后调用其take()方法去取Future对象。
以前没研究过这两者之间的区别。今天看了源代码之后就明白了。
这两者最主要的区别在于submit的task不一定是按照加入自己维护的list顺序完成的。
从list中遍历的每个Future对象并不一定处于完成状态,这时调用get()方法就会被阻塞住,如果系统是设计成每个线程完成后就能根据其结果继续做后面的事,这样对于处于list后面的但是先完成的线程就会增加了额外的等待时间。
而CompletionService的实现是维护一个保存Future对象的BlockingQueue。只有当这个Future对象状态是结束的时候,才会加入到这个Queue中,take()方法其实就是Producer-Consumer中的Consumer。它会从Queue中取出Future对象,如果Queue是空的,就会阻塞在那里,直到有完成的Future对象加入到Queue中。
所以,先完成的必定先被取出。这样就减少了不必要的等待时间
相关文章推荐
- JAVA多线程之Executor&ExecutorService
- ExecutorService实现java多线程
- JAVA多线程计算ExecutorService
- 理解java多线程中ExecutorService使用
- java中的多线程包---CompletionService Executor + BlockingQueue
- Java多线程之ScheduledExecutorService
- Java多线程之ExecutorService
- java 使用ExecutorService 建立多线程
- Java多线程——EXECUTORSERVICE线程池讲解(主要是四种自带线程池的区别)
- java 中多线程池 ExecutorService shutdonw及其多线程执行完成判断
- java创建多线程使用Executors创造ExecutorService
- 【Java多线程】-Timer,TimerTask,ScheduledExecutorService
- java多线程并发executorservice(任务调度)类
- JAVA多线程之ExecutorService
- java中的多线程包--- Timer的缺陷 用ScheduledExecutorService替代
- java多线程 之 CompletionService与ExecutorCompletionService
- JAVA多线程实现方式主要有三种:继承Thread类、实现Runnable接口、使用ExecutorService、Callable、Future实现有返回结果的多线程。其中前两种方式线程执行完后都没
- Java多线程:Callable、ExecutorService、CountDownLatch、Future和FutureTask
- Java多线程之ExecutorService
- java创建多线程使用Executors创造ExecutorService