java - 限制多个执行器中的总线程数

Question

我有六个进程将数据发送到外部服务器。每个进程运行多个“传输”线程以提高性能和并行性(延迟、大文件等)。我每个进程有一个执行程序，每个进程最多 5 个线程。

现在，由于外部服务器仅支持 20 个线程，而我的进程尝试运行总共 30 个线程(每个进程 6 个进程 x 5 个线程)，因此某些线程崩溃。我明白了。

有没有办法在 Java 中创建一个“大线程池”(有 20 个线程)，以将所有进程的总传输线程限制为最多 20 个？

或者，我正在考虑为所有进程创建一个单个执行器，但随后一个进程可能会占用所有线程，而导致其他线程挨饿。

Answer 1

您可以使用单个执行器并实现 bulkhead您的流程的模式。例如，Hystrix 和 Resilience4j 都有现成的实现。