Java并发性：需要同时进行2个webservice调用-这是否正确？

Question

我想同时对2个不同的服务进行Web调用。最后，我将2个响应对象压缩到一个流中。我正在使用Callable，但我不确定我是否以正确的方式处理此事。似乎我仍然会被第一个get（）调用Future阻止，对吗？有人能告诉我我是否在正确的轨道上吗？这是我到目前为止所拥有的：

// submit the 2 calls to the thread pool
ExecutorService executorService = Executors.newFixedThreadPool(Runtime.getRuntime().availableProcessors());
Future<Mono<Response<ProcessInstance>>> processFuture =
        executorService.submit(() -> getProcessInstances(processDefinitionKey, encryptedIacToken));
Future<Mono<Response<Task>>> taskFuture =
        executorService.submit(() -> getTaskResponses(processDefinitionKey, encryptedIacToken, 100, 0));

// get the result of the 2 calls
Optional<Tuple2<Response<ProcessInstance>, Response<Task>>> tuple;
try {
    Mono<Response<ProcessInstance>> processInstances = processFuture.get();
    Mono<Response<Task>> userTasks = taskFuture.get();
    tuple = processInstances.zipWith(userTasks).blockOptional();
} catch (InterruptedException e) {
    log.error("Exception while processing response", e);
    // Restore interrupted state...
    Thread.currentThread().interrupt();
    return emptyProcessResponseList;
} catch (ExecutionException e) {
    log.error("Exception while processing response", e);
    return emptyProcessResponseList;
}

Answer 1

您的代码将一直阻止，直到processFuture完成，然后它将一直阻止，直到taskFuture完成。

这些可调用项将被并行处理，因此在这里您可以节省时间（假设线程池大小

Answer 2

给定：您需要等到两个任务都完成。

如果先结束processFuture，您将立即失败并等待直到taskFuture结束。如果taskFuture首先结束，您将一直阻止，直到processFuture结束，但是taskFuture。get（）调用将在任务完成后立即返回。无论哪种情况，结果都是一样的。

您可以使用CompletableFuture，然后使用CompletableFuture。allOf（）但对于这样简单的东西，您所拥有的一切都很好。另请参见等待未来的列表