java - 在java中并行调用

Question

我有以下代码:

List<ObjectA> allObjects = (List<ObjectA>) objArepository.findAll();

for (ObjectA objA : allObjects) {
        String location = objA.getUrl();

        Client client = utils.createClient();
        WebTarget webTarget = client.target(location).path("/testUrl/" + someString); 
        Invocation.Builder requestBuilder = webTarget.request();
        Response response;
        try {
            response = request.invoke();
            }
        }

我想并行发送这些调用，而不是串行发送这些调用的 for 循环，问题是我没有找到任何示例，而且我不知道如何在 java 中做到这一点

Answer 1

使用ExecutorService .

executorService.invokeAll 可以并行执行一系列任务并等待它们完成。

ExecutorService executor = getExecutorService();
List<Request> requests = getRequests();
List<Callable> tasks = requests.stream()
    .map(r -> new Processor(r))
    .collect(Collectors.toList());

executor.invokeAll(tasks);

如果需要异步调用，请使用executorService.submit或executorService.execute

更新

根据评论，我对上面的代码再补充几句。

getExecutorServices() 返回一个在其他地方创建的 executorService，可能是一个单例，因为创建 executorService 的开销相当大。

getRequests() 返回请求列表，Request 可以是您想要处理的任何内容，例如问题中的 ObjectA。

executorService.invokeAll 接受 Callable 的列表，所以你必须将你的请求封装在可调用对象中。 Processor 是一个用于处理Request 的可调用函数。

其实我觉得这段代码描述性很强，普通Java程序员都能看懂。