likes
comments
collection
share

CompletableFuture异步执行方法

作者站长头像
站长
· 阅读数 12

CompletableFuture.join和get

 //创建第三个异步方法    
CompletableFuture<String> future1 = CompletableFuture.supplyAsync(() -> method1());
CompletableFuture<Integer> future2 = CompletableFuture.supplyAsync(() -> method2());
CompletableFuture<Boolean> future3 = CompletableFuture.supplyAsync(() -> method3());
    
//使用CompletableFuture.allOf()方法等待它们全部完成
CompletableFuture<Void> allFutures = CompletableFuture.allOf(future1, future2, future3);
//所有方法完成之后
allFutures.thenRun(() -> {
//使用join()方法获取每个CompletableFuture对象的结果    
    String result1 = future1.join();
    Integer result2 = future2.join();
    Boolean result3 = future3.join();
    
    // process results
});

CompletableFuture.join()和CompletableFuture.get()都可以用来获取CompletableFuture对象的结果,但它们之间有一些重要的区别。

join()方法是CompletableFuture对象的非阻塞方法,它会立即返回结果(如果已经计算完成),或者等待结果计算完成后返回结果。如果结果还没有算完成,join()方法会抛出一个CompletionException`异常,这个异常包含了导致计算失败的原因。

get()方法是CompletableFuture对象的阻塞方法,它会等待结果计算完成后返回结果。如果结果还没有计算完成,get()方法会阻塞当前线程,直到结果计算。如果结果计算失败,get()方法会抛出一个ExecutionException异常,这个异常包含了导致计算失败的原因。

因此,join()方法更适合在异步代码中使用,因它不会阻塞当前线程,而是立即返回结果或等待结果计算完成后返回结果。而get()方法更适合在同步中使用,因为它会阻塞当前线程,直到结果计算完成。

另外,join()方法比get()方法更快,因为它不需要抛出InterruptedException异常,这个异常会导致线程中断,从而增加了额的开销。因此,如果我们不需要处理线程中断,那么使用join()方法比使用get()方法更快。

CompletableFuture.runAsync和supplyAsync

CompletableFuture.runAsync()和CompletableFuture.supplyAsync()都是用于创建异步任务的方法。

CompletableFuture.run()方法接受一个Runnable对象作为参数,它会异步执行这个Runnable对象,并返回一个CompletableFuture对象。由于Runnable对象没有返回值,因此CompletableFuture对象也没有返回值。

CompletableFuture.supplyAsync()方法接受一个Supplier对象作为参数,它会异步执行这个Supplier对象,并返回一个CompletableFuture对象。由于Supplier对象有返回值,因此CompletableFuture对象也有返回值。

因此,CompletableFuture.runAsync()方法适用于那些没有返回的异步任务,而CompletableFuture.supplyAsync()方法适用于那些有返回值的异步任务。

下面是一个使用CompletableFuture.runAsync()方法的示例:

  CompletableFuture<Void> future = CompletableFuture.runAsync(() -> {
        // do some work
    });    

在这个示例中,我们创建了一个CompletableFuture对象,它异步执行了一个Runnable对象,这个Runnable对象没有返回值。

下面是一个使用CompletableFuture.supplyAsync()方法的示例:

    CompletableFuture<String> future = CompletableFuture.supplyAsync(() -> {
        // do some work
        return "result";
    });

在这个示例中,我们创建了一个CompletableFuture对象,它异步执行了一个Supplier对象,这个Supplier对象有返回值。

总结,CompletableFuture.runAsync()方法适用于那些没有返回值的异步任务,而CompletableFuture.supplyAsync()方法适用于那些有返回值的异步任务。