编写Java CompletableFutures时使用哪个执行器？

Question

我在某个存储库类上有一个方法，它返回completablefuture。完成这些期货的代码使用一个第三方库来阻止。我打算有一个单独的有界executor，这个存储库类将使用它来进行这些阻塞调用。

这里有一个例子：

public class PersonRepository {
    private Executor executor = ...
    public CompletableFuture<Void> create(Person person) {...}
    public CompletableFuture<Boolean> delete(Person person) {...}
}

我的应用程序的其余部分将组成这些期货，并用结果做一些其他的事情。当提供给thenaccept、thencompose、whencomplete等的其他html" target="_blank">函数时，我不希望它们在存储库的executor上运行。

另一个例子：

public CompletableFuture<?> replacePerson(Person person) {
    final PersonRepository repo = getPersonRepository();
    return repo.delete(person)
        .thenAccept(existed -> {
            if (existed) System.out.println("Person deleted"));
            else System.out.println("Person did not exist"));
        })
        .thenCompose(unused -> {
            System.out.println("Creating person");
            return repo.create(person);
        })
        .whenComplete((unused, ex) -> {
            if (ex != null) System.out.println("Creating person");
            repo.close();
        });
}

JavaDoc声明：

为非异步方法的从属完成提供的操作可以由完成当前CompletableFuture的线程执行，也可以由completion方法的任何其他调用方执行。

显然，thenAccept需要更改为thenAcceptAsync，但我不确定这一点。

备选问题：哪个线程完成从thencompose返回的future？

我的猜测是，无论线程完成了什么，它都将是函数参数返回的未来。换句话说，我还需要将whencomplete更改为whencompleteasync。

也许我已经把事情复杂化了，但这感觉它可能会变得相当棘手。我需要非常注意这些期货是从哪里来的。同样从设计的角度来看，如果我返回一个未来，我如何阻止调用方使用我的执行器？感觉就像是破坏了封装。我知道Scala中的所有转换函数都采用一个隐式的executionContext，它似乎可以解决所有这些问题。

Answer 1

附带问题：如果您将中间的completionstage赋给一个变量并在其上调用一个方法，那么它将在同一线程上执行。

主要问题：只有第一个，所以将thenAccept更改为thenAcceptAsync--以下所有的都将在用于接受的线程上执行它们的步骤。

备选问题：从thencompose完成未来的线程与用于compose的线程相同。

您应该将CompletionStages视为在同一线程上快速连续执行的步骤（只需按顺序应用函数），除非您特别希望使用Async在不同的线程上执行该步骤。接下来的所有步骤都是在新线程上完成的。

在当前的设置中,这些步骤将按如下方式执行：

Thread-1: delete, accept, compose, complete

对于第一个accept异步，它变为：

Thread-1: delete
Thread-2: accept, compose, complete