CompletableFuture时，使用this.方法

在使用CompletableFuture时，使用this.方法是指在CompletableFuture的回调方法中调用当前对象的方法。这样做可以方便地在异步任务完成后执行一些操作或者获取异步任务的结果。

例如，我们可以在CompletableFuture的回调方法中使用this.方法来处理异步任务完成后的结果：

public class MyClass {
    public void doSomethingAsync() {
        CompletableFuture<Void> future = CompletableFuture.runAsync(() -> {
            // 异步任务的逻辑
        });
        
        future.thenRun(() -> {
            // 异步任务完成后的操作
            this.someMethod();
        });
    }
    
    public void someMethod() {
        // 处理异步任务完成后的结果
    }
}

在上面的例子中，doSomethingAsync()方法创建了一个CompletableFuture对象，并在异步任务完成后调用了回调方法thenRun()。在回调方法中，我们可以使用this.方法来调用当前对象的someMethod()方法来处理异步任务的结果。

相关问题

CompletableFuture使用this方法

在使用CompletableFuture时，可以使用this方法来引用当前的CompletableFuture对象。this方法返回一个CompletableFuture对象，可以继续对其进行链式操作。下面是一个示例：

CompletableFuture<Integer> future = CompletableFuture.supplyAsync(() -> 42)
    .thenApply(this::multiplyByTwo)
    .thenApply(this::addThree);

private int multiplyByTwo(int number) {
    return number * 2;
}

private int addThree(int number) {
    return number + 3;
}

在上面的示例中，通过使用this::multiplyByTwo和this::addThree，可以将当前CompletableFuture对象作为方法的引用，然后对其进行操作。

CompletableFuture源码详解之java.util.concurrent.CompletableFuture#runAsync(java.lang.Runnable)

CompletableFuture是Java 8中新增的一个类，它提供了一种异步编程的方式，可以方便地进行异步操作和线程间的通信。其中，runAsync方法是CompletableFuture中的一个静态方法，用于执行一个Runnable任务，并返回一个CompletableFuture对象，其中不包含任何返回值。

下面我们来看一下runAsync方法的源码实现：

public static CompletableFuture<Void> runAsync(Runnable runnable) {
    return asyncRunStage(asyncPool, runnable);
}

private static CompletableFuture<Void> asyncRunStage(Executor e, Runnable f) {
    if (f == null) throw new NullPointerException();
    CompletableFuture<Void> d = new CompletableFuture<Void>();
    e.execute(new AsyncRun(d, f));
    return d;
}

static final class AsyncRun implements Runnable {
    final CompletableFuture<Void> d; final Runnable f;
    AsyncRun(CompletableFuture<Void> d, Runnable f) { this.d = d; this.f = f; }
    public void run() {
        try {
            f.run();
            d.complete(null);
        } catch (Throwable ex) {
            d.completeExceptionally(ex);
        }
    }
}

从代码中可以看出，runAsync方法会调用asyncRunStage方法，将任务和线程池传入异步执行。

在asyncRunStage方法中，首先会判断参数是否为空，如果为空就抛出NullPointerException异常。

接下来，会创建一个CompletableFuture对象d，并将它和任务f封装到AsyncRun对象中。

然后，通过线程池e执行AsyncRun对象，即执行任务f，并将结果存放到CompletableFuture对象d中。

如果任务f执行成功，就调用CompletableFuture对象的complete方法将结果设置为null；如果任务f执行失败，就调用CompletableFuture对象的completeExceptionally方法将异常信息设置到CompletableFuture对象中。

最后，异步执行过程结束，返回CompletableFuture对象d。

总结一下，CompletableFuture的runAsync方法通过将任务封装到AsyncRun对象中，并异步执行任务，最后将结果存放到CompletableFuture对象中，实现了异步编程和线程间通信。