我想在上使用ExecutorCompletionService预定义的构造函数BlockingQueue。
ExecutorCompletionService
BlockingQueue
任何人都可以提供代码片段来说明如何完成此操作。看来只有采取AA BlockingQueue与Future秒。这与必须使用Callables 完成提交的事实如何匹配?
Future
Callable
我在这里有点困惑-请帮助…
将Callables提供给submit()将被包裹起来内部为FutureTaskS,和它的那些(一个或周围的包装),最终将被插入到设置队列。不过,这只是实现细节。(并且,请注意,将结果插入队列中的这种用例是在中使用受保护done()方法的主要原因FutureTask。)合同说,使用了产生结果的功能,最终结果出来了。在Future从队列中抽取s为先前提交的功能,最终的结果。
Callables
submit()
FutureTask
done()