僅使用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），這可能有助於調試並製作漂亮的線程轉儲。