我用ForkJoin和FixedSizeThreadPool对我的问题做了两个实现,我想比较它们的性能。在我的问题中,每个任务将创建一些子任务,并将它们再次提交给executor服务。在fork-join实现中,我使用fork(),在另一个实现中,我使用execute()。
显然,我的主线程需要等待整个工作完成。在fork-join中,我可以优雅地检查isQuiescent()属性以确保所有任务都已完成,但在另一种情况下,我想不出还有什么比手动计算我创建了多少任务以及有多少任务已完成更好!这个解决方案有效,但代价是一个共享变量,这显然会降低我的性能。
我不能只使用shutdown(),因为这样子任务就不会被调度(它们将得到RejectedExecutionException)。
有谁知道比计算任务更好的解决方案吗?
发布于 2013-01-21 23:38:47
实际上,shutdown会一直等到之前提交的所有任务都完成。对于您的用例,请查看ExecutorCompletionService。
https://stackoverflow.com/questions/14441540
复制相似问题