java - ThreadPoolExecutor， future : correlating requests and responses

Question

我正在尝试使用 ThreadPoolExecutor连同 Future (结果)和 Callable (要执行的任务)，但我想不出一种将输入(可调用)与相应结果( future )相关联的简单方法，似乎唯一明智的方法是创建一个包含的包装器( 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);
    }
}