java 异步发展史 Runnable Callable Future CompletableFuture

目录

只管执行不管结果

不仅执行还要结果

java 1.5

java 1.8

---

很多规范中的 api 最开始的都是同步，比如 jdbc、jdk 1.0 中的 io、servlet 规范都是针对同步的。异步是后面才诞生的一个概念。

很多时候在做功能时，针对大批量数据处理有批量处理的需求

针对这个有两种做法

只管执行不管结果

这种方式简单粗暴，尤其是在线上，如果请求发送出去不管响应结果的话，出现异常有时不知道怎么回事对方没收到（我给对方钱了但是因为网络原因对方没收到，但是自己扣款了，这个有点尴尬）。

对应 jdk 1.0 Runnable

不仅执行还要结果

这种方式符合大多数需求，不仅发出去请求了，后面我还要知道调用的服务是否正常，不能我给你数据你返回了正常但是你提示正常自己却说自己没收到（我给你钱了你也说收到了最后你却说没收到，哈哈哈）。

这种方式如果逻辑内只调用了一个外部业务逻辑耗时不长（1s内）还好，但是如果调用了很多的话，程序执行之间是串行的话响应时间会很长，这样会有用户体验不好的问题。

java 1.5

从 java 1.5 开始大佬 Doug Lea (很多java api的作者)提供了 java.util.concurrent.Future 和 java.util.concurrent.Callable 接口，使异步执行成为可能。

它们之间功能不同，是包含的关系

Callable 用户执行有返回值的线程，不同于 Runnable

Future 对应 Callable 的返回值，对应定义的返回值对象

Future 的 get() 有两个

V get()
V get(long timeout, TimeUnit unit)

但是这样有一个问题，Future 的 get() 获取结果是阻塞的，需要等待。

调用无参的 get() 逻辑执行未结束获取的值会是null，这不是我们想要的。当然可以通过有参的 get() 来设置响应的最大时长，但是这样比较麻烦。

有没有那种类似观察者模式事件通知的方式来处理这个问题？针对这个问题，java 的大佬 Doug Lea 想了其他办法。

java 1.8

在这个版本中写了一个 java.util.concurrent.CompletableFuture，通过 whenComplete() 回调获取返回值，用于处理 Future 获取值阻塞的问题。

然而 CompletableFuture 也有缺陷，有待补充。