如何并行调用返回未来的方法？

Question

我有一个如下所示的异步方法，它调用我的 Task 类，我的 Task 类完成所有工作。

    @Override
    public Future<DataResponse> executeAsync(DataKey key) {
        Future<DataResponse> future = null;

        try {
            Task task = new Task(key, restTemplate);
            future = executor.submit(task); 
        } catch (Exception ex) {
            // logging exception here
        }

        return future;
    }

下面是我的 Task 类，它完成了所有工作：

public class Task implements Callable<DataResponse> {

    private DataKey key;
    private RestTemplate restTemplate;

    public Task(DataKey key, RestTemplate restTemplate) {
        this.key = key;
        this.restTemplate = restTemplate;
    }

    @Override
    public DataResponse call() throws Exception {
        // some code here
    }
}

现在我需要并行调用executeAsync 方法，然后创建一个List<DataResponse> 对象并返回它。

@Override
public List<DataResponse> executeSync(DataKey key) {
    List<DataResponse> responseList = new ArrayList<DataResponse>();

    // make a List of DataKey using single key passed to this method.       
    List<DataKey> keys = new ArrayList<DataKey>();

    for(DataKey key : keys) {


    }
}

如何并行调用executeAsync 方法并返回responseList？在我的keys 列表中，最多有六个DataKey 对象。

Answer 1

如果您希望返回包含由Task#call 返回的DataResponse 对象的List<DataResponse>，则不能异步执行此操作。您需要在 executeSync 内部进行阻塞以等待所有期货的结果。

List<Future> futures = new ArrayList<>(keys.size());
for(DataKey key : keys) {
    Future<DataResponse> future = executeAsync(key);
    futures.add(future);
}

for (Future<DataResponse> future : futures) {
    try {
        responseList.add(future.get());
    } catch (Exception e) {
        // do something else.
    }
    return responseList
}

使用Future 的更合适的解决方案是使用CompletionService，详见here。

在 Java 8 中，您应该使用 CompletableFuture（或 Guava 的 ListenableFuture）来执行异步任务。您仍然可以执行我上面所做的操作，或者您可以更改代码以充分利用延续任务。

Answer 2

您可以调用 Executor 服务的 invokeAll 方法并将任务列表提交给它。 Executor Service 将并行执行任务。

https://docs.oracle.com/javase/7/docs/api/java/util/concurrent/ExecutorService.html#invokeAll(java.util.Collection)

这将与以下内容相同： 1. 在 executeSync 方法中从 for 循环中并行调用 executeAsync。 2. 在executeSync方法中从for循环依次调用executeAsync方法。

Answer 3

没有理由并行执行它，因为它在内部已经并行运行。您唯一需要的是为每个项目调用异步方法并将生成的Futures 存储在列表中。在此循环结束后，您需要遍历那些 Futures 的列表，并在每个上面调用 get() 给出结果。这些结果列表您将作为返回值返回。