2017年7月即將發(fā)布的Java 9將會新增和修訂不少功能和特性。在搜索JDK增強提議（JEP）時發(fā)現(xiàn)，JEP 266對CompletableFuture進行了一些有趣的改進，更新并發(fā)功能和支持Reactive Streams。

本文的焦點就是JEP 266的改進和一些有趣的特性，它極有可能成為Java 9中最常用的特性之一。

JEP 266改進計劃
JEP 266是Oracle草擬JDK增強協(xié)議里面的一員，其中對并發(fā)進行了大量的更新。根據(jù)提案，將要進行更新的特性有：

• 支持Reactive Streams發(fā)布-訂閱框架接口
• 對CompletableFuture API進行更新，例如支持延遲、超時、子類化和其它方法
• 其它一般改進，例如小調整和javadoc規(guī)范重寫

本文重點關注前兩個改進。首先，Java 9將支持Reactive Streams，這是一個來自Java社區(qū)的改進計劃，旨在改進開發(fā)人員的并發(fā)工作流程。其次是CompletableFuture API提供的幾個fixer-uppers，可以讓開發(fā)人員回到Future<T>。

Flow類
Reactive Streams發(fā)布-訂閱框架里面將嵌套一個Flow類，以及開發(fā)人員可以用來創(chuàng)建自定義組件使用的SubmissionPublisher。

先從最上面的說起，Reactive Streams主要解決背壓（back-pressure）問題。當傳入的任務速率大于系統(tǒng)處理能力時，數(shù)據(jù)處理將會對未處理數(shù)據(jù)產生一個緩沖區(qū)。

與此同時，我們還與Akka團隊的高級開發(fā)人員Konrad Malawski進行了溝通，他是Reactive Streams計劃的***，解釋了Reactive Streams的重要性以及如何使用。

Oracle指出，新的增強將包括“一個很小的接口，其定義符合（來自Reactive Stream initiative的）廣泛參與”，這就是Flow類的來源。

Reactive Streams由4個Java接口構成：

• 處理器（Processor）
• 發(fā)布商（Publisher）
• 訂閱用戶（Subscriber）
• 訂閱（Subscription）

Flow類允許相互關聯(lián)的接口和靜態(tài)方法來建立流控制組件，其中發(fā)布者產生由一個或多個訂閱者消費的項目，每個訂閱者由訂閱管理。

Reactive Streams構建在java.util.concurrent.Flow容器對象下，開發(fā)者可以在這里找到Flow.Publisher，一個用作lambda表達式或方法引用的賦值目標功能接口。該接口可以讓開發(fā)者更容易生成Flow.Subscription元素，并且將它們鏈接在一起。

另一個元素Flow.Subscriber，是異步工作機制，由請求觸發(fā)。它可以從Flow.Subscription請求多個元素，開發(fā)者還可以根據(jù)需要自定義緩沖區(qū)大小。

這些接口適用于并發(fā)和分布式異步設置，它們之間的通信依賴于一種簡單的流控制形式，可用于避免資源管理問題。

感興趣的用戶可以在java.util.concurrent.Flow下面查看代碼示例。

目前已有一些第三方庫實現(xiàn)了Reactive Streams接口，你無需等到Java 9發(fā)布便可嘗試一下。

CompletableFuture新特性
Java 8引進了CompletableFuture，繼承自Future<T>。Futures是非常有用的，當我們不希望或者不需要一個直接計算結果的時候，我們會收到一個Future對象來保存計算完成時分配的實際結果。通過調用complete()方法并且無需異步等待即可顯式完成。它還允許在一系列操作中構建管道數(shù)據(jù)流程。

這樣，任何類型的可用值都可以在Future中使用默認返回值，即使計算沒有完成。這也將成為CompletableFuture提案更新的一部分，包括延遲和超時、更好地支持子類化和一些實用方法。

更多CompletableFuture功能改進和提案，大家可以前往這里查看。

總結
Java 9即將帶來一些重大的更新與改進，其中JEP 266會是最有趣的一部分改進。它的改進方案主要來自社區(qū)的一些倡議，旨在幫助開發(fā)人員解決異步處理方面的一些重大問題。