并发编程-ExecutorCompletionService解析

原文英文,约500词,阅读约需2分钟。发表于:

我们在并发编程中,目前大部分做法都是将任务添加到线程池中,并拿到Future对象,将其添加到集合中,等所有任务都添加到线程池后,在通过遍历Future集合,调用future.get()来获取每个任务的结果,这样可以使得先添加到线程池的任务先等待其完成,但是并不能保证第一个添加到线程池的任务就是第一个执行完成的,所以会出现这种情况,后面添加到线程池的任务已经完成了,但是还必须要等待第一个任务执行完成并处理结果后才能处理接下来的任务。

并发编程中,使用ExecutorCompletionService可以保证任务的执行顺序与提交顺序无关。通过将任务包装成QueueingFuture对象,任务执行完成后将结果添加到阻塞队列中,可以通过poll或take方法获取执行结果。可以用于不关注任务顺序和结果顺序的场景。

相关推荐 去reddit讨论