如何运行一系列线程并等待它们在完成之前完成?

public void doSomething(Set<String> emails){
        CompletableFuture.allOf(emails.stream()
                .map(email -> yourService.doAsync(email)
                        .exceptionally(e -> {
                            LOG.error(e.getMessage(), e);
                            return null;
                        })
                        .thenAccept(longResult -> /*do something with result if needed */))
                .toArray(CompletableFuture<?>[]::new))
            .join();
    }

此代码将启动其他线程中的每个doAsync方法调用,并等待所有这些任务完成。

你的doAsync方法

@Async
public CompletableFuture<Long> doAsync(String email){
    //do something
    Long result = ...
    return CompletableFuture.completedFuture(result);
}

如果doSomething方法和doAsync方法在同一个服务类中,您应该自注入服务

@Autowired
@Lazy
private YourService yourService

yourService.doAsync(email)

以异步方式运行它。