java中CompletableFuture异步执行方法

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()方法适用于那些有返回值的异步任务。

到此这篇关于java中CompletableFuture异步执行方法的文章就介绍到这了,更多相关java CompletableFuture异步执行 内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家！

最新评论