ThreadPoolExecutor，Futures：關聯請求和響應

Question

我試圖使用ThreadPoolExecutor以及Future（結果）和Callable（要執行的任務），但我找不到一個簡單的方法來關聯輸入（Callable）與相應的結果（未來），似乎唯一明智的方法是創建一個包含所有項目的包裝器（example），但這對於這樣一個簡單的任務可能會造成太多開銷。

我錯了嗎？任何建議的選擇？

Answer 1

更好的方法是使用invokeAll()方法而不是submit()。您需要提供一個Callable的集合，它將以與您的任務相同的順序返回一個Futures集合。而且，invokeAll()可以讓你定義超時，所以你不需要鎖存器。它會是這樣的：

List<Callable> jobs = new ArrayList<>(requests.size()); 
for (String request : requests) { 
    jobs.add(new MyCallable(request)); 
} 
List<Future<ProcessedResponse>> futures = executor.invokeAll(jobs, timeout, TimeUnit.MILLISECONDS); 
Iterator<String> it = requests.iterator(); 
for (Future<ProcessedResponse> future: futures) { 
    String request = it.next(); // This request corresponds to this future 
    if (future.isDone()) { 
     results.add(new Result(request, future.get())); 
    } else { 
     future.cancel(true); 
    } 
}