executorThreadPool在任务完成或超时过期时检查

Question

我正在使用executorservice,每个webservice调用都会产生大约9-10个可调用任务,并提交给executorservice线程池。线程池大小为100的应用程序只有一个executorService。当我提交调用时，我有一个2 For循环。外部循环运行到指定的超时期满或完成的散列集大小==提交的任务大小；内部循环将遍历调用项，如果isDone()==true，则将这些调用项收集到“completed”hashset中。当outerloop条件失败时，我循环遍历'completed'hashset中的调用项并聚合结果。问题是，我确信有一个比使用2个循环更优雅的解决方案。

如果所有任务完成或超时到期，我可以得到通知的最佳方式是什么？任何框架，库等或设计模式？

Answer 1

你基本上有两种选择，拉或推。

Pull是您已经尝试过的方法--发出所有异步任务，保留对它们的引用，并调用isDone（）直到它们全部完成。

另一方面，Push将调用任务和通知任务分开。您将调用异步任务，然后该方法将立即返回。通知将由任务本身处理，它们需要在工作完成时通知。

我个人更喜欢push方法，因为它可以清理代码，并分离调用任务和处理结果的关注点。不管怎样都好。