分类导航

程序问答发布时间：2022-06-01 发布网站：大佬教程 code.js-code.com

大佬教程收集整理的这篇文章主要介绍了使用 completablefuture 以异步方式重写 loop-with-break 逻辑，大佬教程大佬觉得挺不错的，现在分享给大家，也给大家做个参考。

如何解决使用 completablefuture 以异步方式重写 loop-with-break 逻辑？

开发过程中遇到使用 completablefuture 以异步方式重写 loop-with-break 逻辑的问题如何解决？下面主要结合日常开发的经验，给出你关于使用 completablefuture 以异步方式重写 loop-with-break 逻辑的解决方法建议，希望对你解决使用 completablefuture 以异步方式重写 loop-with-break 逻辑有所启发或帮助；

我在纯 Java 中有这样的逻辑，我想用异步代码重写：

for (Batch batch : batches) {
    int required = N;
    for (Item item : batch.items()) {
        Response response = clIEnt.syncrequest(new request(item));
        int score = score(responsE);
        required -= score;
        if (required < 0) {
            break;
        }
    }
}

我需要收集 N 个分数，因此我正在阻止请求，直到达到分数。如果我替换

Response response = clIEnt.asyncrequest(new request(item));

类似的东西

CompletableFuture<Response> responseFuture = clIEnt.asyncrequest(new request(item));
responseFuture.whenCompleted((response,exception) -> {...});

这意味着将提交对所有项目的请求（如果我需要，例如只有 5 个才能达到分数）。是否有一些最佳实践如何以异步方式做到这一点？我有一个想法，添加一些可变计数器，当完成时会增加，如

CompletableFuture<Response> responseFuture = CompletableFuture.supplyAsync(() -> {
    if (notEnoughscore(counter) {
        return clIEnt.asyncrequest(new request(item));
    } else {
        CompletableFuture.completedFuture(null);
    }
});

但在这种情况下，据我所知，可能会触发不必要的客户端请求。