仅使用ExecutorService中的线程子集

Question

在典型的JAVA应用程序中，配置用于管理全局线程池的全局ExecutorService。可以说，我配置100个线程的固定的线程池：

ExecutorService threadPool = Executors.newFixedThreadPool(100); 

现在让我们说，我有1000个文件的列表上传到服务器，并为每个上传我创建了一个调用将要处理的上传这一个文件。

List<Callable> uploadTasks = new ArrayList<Callable>(); 
// Fill the list with 1000 upload tasks 

我该如何限制并发上传的最大数量，例如5？

，如果我做

threadPool.invokeAll(uploadTasks); 

我没有在我的1000个任务将多少线程取得控制权。潜在的100个上传文件将并行运行，但我只想要最大值5.我想创建某种子执行程序，它使用父执行程序的一部分线程。 我不想创建一个新的分离executorService只是为了上传，因为我想管理我的线程池全局。

你们有没有人知道如何做到这一点，或者如果现有的实施存在？理想的情况是类似

ExecutorService uploadThreadPool = Executors.createSubExecutor(threadPool,5); 

非常感谢，

安东尼

Answer 1

在一个典型的Java程序，一个配置管理全局线程池全球的ExecutorService。

我没有这样做，但也许我是非典型的。 :-)回到你的问题：

由于具有防护（可能使用Semaphore您Callable的内线只会扰乱互相等待您的全球Executor哪些任务，你就必须要么

• 使用一些外部逻辑确保只有5个作业在任何时候运行，这本身可以是一个Callable提交给你的一个Executor。这可以通过用一些逻辑包装你的下载作业来完成，这将从队列中提取下一个作业（包含网址或任何其他内容），然后您将这些“排水下载队列”作业中的五个提交到您的Executor并称之为完成。但我并不典型，我只是
• 使用单独的Executor下载。这也让你能够适当地命名你的线程（在Executor的ThreadFactory），这可能有助于调试并制作漂亮的线程转储。