使用 ExecutorService 线程安全聚合的 Java 回调总计

Question

关闭。这个问题需要多问 focused 。目前不接受答案。

---

想要改进此问题吗？更新问题，使其仅关注一个问题 editing this post .

已关闭 8 年前。

Improve this question

在我的 main 方法中，我声明了 30 个可运行的工作线程，然后向每个工作线程传递了他们需要完成的一些任务。我希望它能够实时、汇总地报告，并且不会阻碍工作人员的执行。实时报告应该只是打印到控制台并包含一些统计信息

伪代码:

1. 创建 30 个工作线程的线程池。
2. 为每个 worker 创造 x 个就业岗位。
3. 启动计时器来跟踪性能并开始执行每个工作线程。
4. 每次工作人员完成一项任务时，它都应该回调 main 中的一个方法，该方法将增加一个 int 来跟踪已完成的任务数量。这必须是线程安全的
5. 每隔 5 秒，在屏幕上打印出已完成的作业数量，直到所有作业都完成。

Answer 1

逻辑是合理的，只需使用 AtomicInteger.incrementAndGet() 进行计数即可。

http://docs.oracle.com/javase/7/docs/api/java/util/concurrent/atomic/AtomicInteger.html