1. 首页
  2. java9教程

015-十五、Java 9 – CompletableFuture API ( 上 )

引言

CompletableFuture 类是在 Java 8 引入的。用于表示一个 Feture 的状态,可以通过设置其值或状态来明确表示 Feture 处于完成状态

说起来特拗口,理解起来就简单了

那个,Java 8 不是引入了并发编程了,对吧。并发编程里有一个概念就是并发执行是否完成了。这个是否完成了是由 java.util.concurrent.CompletionStage 来表示的。然后呢,CompletableFutureCompletionStage 的父类。

如果你对 Java 的并发编程熟悉,那么一定直到,当并发完成时可以支持一个回调,这个回调也是由 CompletableFuture 提供的。

有时候会觉得,一个特性,应该在它出现的时候就比较完善了,直到别人提出了新的思维,才觉得原来还有改进的空间,就比如这个 CompletableFuture

Java 9 竟然还给它添加了一些东西:

1、 支持延误和超时 ( timeout ) 机制
2、 支持子类化
3、 添加了一些新的工厂方法

支持延误和超时机制

这两个功能是通过新增两个方法来达成的

方法 说明
completeOnTimeout(Tvalue,longtimeout,TimeUnitunit) 如果在指定时间内没完成,则返回一个指定的值
orTimeout(longtimeout,TimeUnitunit) 如果在指定的时间内没完成,则抛出一个异常TimeoutException

这两个方法的看起来是差不多的,都是在指定时间内没完成则执行一个动作,只不过前者是返回一个指定的值,后者则直接抛出异常

这两个方法的原型如下


public CompletableFuture<T> completeOnTimeout(T value, long timeout, TimeUnit unit) public CompletableFuture<T> orTimeout(long timeout, TimeUnit unit)

范例

在我们的工作目录创建一个文件 CompletableFutureTimeoutTester.java 并输入以下内容


import java.util.concurrent.CompletableFuture; import java.util.concurrent.ExecutionException; import java.util.concurrent.TimeUnit; class CompletableFutureTimeoutTester { public static void main(String[] args) { try { CompletableFuture<Integer> future = CompletableFuture.supplyAsync(CompletableFutureTimeoutTester::computeEndlessly) .orTimeout(1, TimeUnit.SECONDS); future.get(); // 显式等待超时 } catch ( Exception e ) { System.out.println(e); } try { int defaultValue = 7; CompletableFuture<Integer> future = CompletableFuture.supplyAsync(CompletableFutureTimeoutTester::computeEndlessly) .completeOnTimeout(defaultValue, 1, TimeUnit.SECONDS); Integer result = future.get(); // 显式等待超时 System.out.println(result); } catch ( Exception e ) { System.out.println(e); } } private static Integer computeEndlessly() { try { Thread.sleep(Integer.MAX_VALUE); } catch (InterruptedException e) { Thread.currentThread().interrupt(); } return 42; } }

运行结果如下


[penglei@tech.souyunku.com java9]$ javac CompletableFutureTimeoutTester.java && java CompletableFutureTimeoutTester java.util.concurrent.ExecutionException: java.util.concurrent.TimeoutException

从运行的结果中可以看到,如果执行超时, orTimeout() 方法直接抛出了一个异常,而 completeOnTimeout() 方法则是返回默认值

写完了如果写得有什么问题,希望读者能够给小编留言,也可以点击[此处扫下面二维码关注微信公众号](https://www.ycbbs.vip/?p=28 "此处扫下面二维码关注微信公众号")

JS中文网,Javascriptc中文网是中国领先的新一代开发者社区和专业的技术媒体,一个帮助开发者成长的社区,是给开发者用的 Hacker News,技术文章由为你筛选出最优质的干货,其中包括:Android、iOS、前端、后端等方面的内容。目前已经覆盖和服务了超过 300 万开发者,你每天都可以在这里找到技术世界的头条内容。

本文著作权归作者所有,如若转载,请注明出处

转载请注明:文章转载自「 Java极客技术学习 」https://www.javajike.com

标题:015-十五、Java 9 – CompletableFuture API ( 上 )

链接:https://www.javajike.com/article/1430.html

« 016-十六、Java 9 – CompletableFuture API ( 中 )
014-十四、Java 9 – 多分辨率图像 API»

相关推荐

QR code