Java不等待异步调用响应

Question

我使用Java中的ExecutorService创建一个线程池，每个线程在其中执行一些异步任务/调用另一个服务。我不想等待回复，但无论何时回复都会返回。

ExecutorService executor = Executors.newFixedThreadPool(5);  // Class var

// Method
Future<Object> future = executor.submit(new TransportService(requestVO));
Object response = future.get(5, TimeUnit.SECONDS);  // blocking  

这样做将等待第一个请求完成，然后返回结果。问题是，第二个请求必须等待第一个请求的响应返回，并且只有在这之后才会被处理。如果我使用CompletableFuture的supplySync（）方法，也会发生同样的情况，因为我还必须使用join（）来获取响应。

我希望所有的请求都经过检查，并在收到时返回回复。这是可以实现的吗？流程仍然需要同步。

Answer 1

您需要在集合中添加期货，然后在最后调用加入/获取。

Collection<Future<Object>> futures = new ArrayList<>();
// schedule calls independantly
for(Request vo: requests) {
   futures.add(executor.submit(new TransportService(requestVO)));
}
// actually handle result
for(Future<Object> future: futures) {
   Object response = future.get(5, TimeUnit.SECONDS);
}

在这种情况下，您将安排多达五个作业。

Answer 2

您可能可以使用CompletableFuture将异步任务提供给ExecutorService：

    CompletableFuture<String> future = CompletableFuture.supplyAsync(() -> "foo", Executors.newSingleThreadExecutor());
    future.thenAccept(s -> System.out.println("done: " + s));

CompletableFuture有多个然后 链接完成后后续行动的方法。