我正在處理一些處理多個(gè) REST 調(diào)用的 Java 代碼call1()call2()call3()...我想并行化這些調(diào)用，但同步執(zhí)行我的主要代碼。我用lamba和并行流制作了一個(gè)POC：List<Runnable> list = new ArrayList();list.add(() -> {call1()});list.add(() -> {call2()});list.add(() -> {call3()});list.add(...);list.parallelStream() .forEach(Runnable::run);你有其他解決方案嗎？我還檢查了使用來自 Jersey 客戶端的異步調(diào)用，但這需要更多的代碼更改。
1 回答
鴻蒙傳說
TA貢獻(xiàn)1865條經(jīng)驗(yàn) 獲得超7個(gè)贊
您正在尋找的只是異步運(yùn)行您的調(diào)用。您可以使用CompletableFutures 提交任務(wù)，然后等待它們完成：
list.stream() //you don't really need a parallel stream
.map(CompletableFuture::runAsync)
.collect(Collectors.toList()) //make sure all tasks are submitted
.stream()
.forEach(CompletableFuture::join);
這將提交所有任務(wù)（異步運(yùn)行），然后等待每個(gè)任務(wù)完成運(yùn)行。發(fā)生這種情況時(shí)，該方法將返回。
您可能需要控制異步任務(wù)的線程池。這是一個(gè)使用 10 線程池的示例：
ExecutorService es = Executors.newFixedThreadPool(10);
list.stream()
.map(r -> CompletableFuture.runAsync(r, es))
...
添加回答
舉報(bào)
0/150
提交
取消