Để CompletableFuture exception() xử lý ngoại lệ supplyAsync()

In lại 作者：行者123 更新时间：2023-12-04 08:32:59 27 4

private void doesNotCompile() {
    CompletableFuture sad = CompletableFuture
            .supplyAsync(() -> throwSomething())
            .exceptionally(Throwable::getMessage);
}

private String throwSomething() throws Exception {
    throw new Exception();
}

private void compiles() {
    CompletableFuture thisIsFine = CompletableFuture.supplyAsync(() -> {
        thử {
            throwSomething();
            return "";
        } catch (Exception e) {
            throw new RuntimeException(e);
        }
    }).exceptionally(Throwable::getMessage);
}

import com.machinezoo.noexception.Exceptions;
import java.util.concurrent.CompletableFuture;

public class SO64937499 {

    public static void main(String[] args) {
        CompletableFuture sad = CompletableFuture
            .supplyAsync(Exceptions.sneak().supplier(SO64937499::throwSomething))
            .exceptionally(Throwable::getMessage);
    }

    private static String throwSomething() throws Exception {
        throw new Exception();
    }
}

final class CheckedSupplier implements Supplier {

    private final SupplierThatThrows supplier;

    CheckedSupplier(SupplierThatThrows supplier) {
        this.supplier = supplier;
    }

    @Ghi đè
    public T get() {
        thử {
            return supplier.get();
        } catch (Throwable exception) {
            throw new RuntimeException(exception);
        }
    }
}



@FunctionalInterface
interface SupplierThatThrows {

    T get() throws Throwable;
}

 CompletableFuture sad = CompletableFuture
        .supplyAsync(new CheckedSupplier<>(SO64937499::throwSomething))
        .exceptionally(Throwable::getMessage);

27 4 0

• java CompletableFuture.thenCombine 返回 CompletableFuture 的 CompletableFuture

  我的应用程序中有 3 种不同的方法。全部返回CompletableFuture .我想并行执行方法 1 和 2。完成方法 1 和 2 后，我想使用方法 1 和 2 返回值的参数触发方法 3。 代码示例

• java - 返回一个包含 CompletableFuture 列表的 CompletableFuture

  我正在尝试加快对多个 API 的调用。 在下面的代码中，getFilteredEvents是当前同步版本。我有这样的感觉 map(x -> x.getFilteredEvents(eventResea

• Java CompletableFuture，什么时候调用 completableFuture.handle ？

  Q1。我的理解是，如果 future 正常或异常完成，就会调用 completableFuture.handle 。但是超时情况又如何呢？ 第二季度。在哪里检查 completableFuture 的

• java - CompletableFuture.supplyAsync 与新的 CompletableFuture()

  我不明白这里发生了什么 CompletableFuture/supplyAsync。 如果我从先前实例化的 CompletableFuture 对象调用 supplyAsync 方法，它永远不会完成:

• java - 将第一个 CompletableFuture 的结果传递给链上的其他 CompletableFuture

  我有一个返回 CompletableFuture 的异步方法。 private CompletableFuture asyncA(..) 我公开了一个必须返回 CompleteableFuture 的

• java - CompletableFuture.runAsync 与 CompletableFuture 数组

  我在项目中找到了这段代码: int threadCount = 10; CompletableFuture[] futures = new CompletableFuture[threadCount]

• java - 在另一个 CompletableFuture 的结果上应用多个 CompletableFuture 的最佳方法是什么？

  让我们举个例子:我们有四种方法: CompletableFututre loadAndApply(SomeObject someObject); CompletableFuture loadData(

• java - 当另一组 CompletableFuture 完成时，你如何完成一个 CompletableFuture？

  我有一个可完成的 future (future1)，它创建了 10 个可完成的 future (futureN)。只有当所有 futureN 都完成时，有没有办法将 future1 设置为完成？ 最佳

• java - 返回 CompletableFuture 还是 CompletableFuture？

  我想编写一个返回 CompletableFuture 的异步方法. future 的唯一目的是跟踪方法何时完成，而不是其结果。返回CompletableFuture会更好吗？或 Completable

• java - CompletableFuture.allOf() 在等待完成时是否比使用 CompletableFuture.join() 的循环有任何优势？

  我正在对我的数据库进行多次异步调用。我将所有这些异步调用存储在 List> list 上.我想一起收集所有结果，所以我需要等待所有这些调用完成。 一种方法是创建一个 CompletableFuture

• generics - 为什么编译器给我这不能从 CompletableFuture

  我正在尝试使用 CompletableFuture 链接一些文件处理程序，它应该返回 CompletableFuture : CompletableFuture allGen = loadFile1(

• java - CompletableFuture.allOf 已完成，即使其列表中的一个 CompletableFuture 尚未完成

  我有 2 个 CompletableFuture。 task2 只能在 task1 完成后启动。然后，我需要等待所有任务完成。在下面的代码中，程序在 task1 结束后结束。 task2 开始但未完成

• java - CompletableFuture.allOf 已完成，即使其列表中的一个 CompletableFuture 尚未完成

  我有 2 个 CompletableFuture。 task2 只能在 task1 完成后启动。然后，我需要等待所有任务完成。在下面的代码中，程序在 task1 结束后结束。 task2 开始但未完成

• java - 将两个 CompletableFutures 链接在一起，每个 CompletableFutures 返回列表

  我很难弄清楚这一点，并且可以向那些比我更有经验和知识的人寻求帮助。 基本问题是我需要获取对象列表，然后对于返回的每个对象，获取一些详细信息，并将详细信息缝合到对象中。我希望在这方面保持高效；我需要首先

• java - CompletableFuture allof(..).join() 与 CompletableFuture.join()

  我目前正在使用 CompletableFuture supplyAsync() 方法将一些任务提交到公共(public)线程池。这是代码片段的样子: final List>> completableF

• java - 为什么 CompletableFuture.allOf 声明为 CompletableFuture?

  为什么是CompletableFuture.allOf声明为 CompletableFuture而不是返回结果集合或其他东西？我认为制作 CompletableFuture.anyOf 是个好主意返回

• java - CompletableFuture recoverWith 等效？即异常但返回 CompletableFuture

  我没有看到处理具有异步结果的异常的明显方法。 例如，如果我想重试一个异步操作，我会期待这样的事情: CompletionStage cf = askPong("cause error").handle

• java - 如何将 1 个 completablefuture 划分为流中的多个 completablefuture？

  比如我有这样的方法: public CompletableFuture getPage(int i) { ... } public CompletableFuture getDocument(

• java - 引用 CompletableFuture 中的字段，它又可以是 CompletableFuture : java

  我正在调用一个返回 CompletableFuture 的服务。 输出结构如下。 Class Output { public String name; public Integer a

• java - 从 List 转换为 CompletableFuture

  我正在尝试转换 List>至CompletableFuture> .当您有许多异步任务并且需要获取所有这些任务的结果时，这非常有用。 如果其中任何一个失败，那么最终的 future 将失败。这就是我的