您好,登錄后才能下訂單哦!
本篇內容介紹了“Java9的基本功能有哪些”的有關知識,在實際案例的操作過程中,不少人都會遇到這樣的困境,接下來就讓小編帶領大家學習一下如何處理這些情況吧!希望大家仔細閱讀,能夠學有所成!
JEP 266改進計劃
JEP 266是Oracle草擬JDK增強協議里面的一員,其中對并發進行了大量的更新。根據提案,將要進行更新的特性有:
支持Reactive Streams發布-訂閱框架接口
對CompletableFuture API進行更新,例如支持延遲、超時、子類化和其它方法
其它一般改進,例如小調整和javadoc規范重寫
本文重點關注前兩個改進。首先,Java 9將支持Reactive Streams,這是一個來自Java社區的改進計劃,旨在改進開發人員的并發工作流程。其次是CompletableFuture API提供的幾個fixer-uppers,可以讓開發人員回到Future<T>。
Flow類
Reactive Streams發布-訂閱框架里面將嵌套一個Flow類,以及開發人員可以用來創建自定義組件使用的SubmissionPublisher。
先從最上面的說起,Reactive Streams主要解決背壓(back-pressure)問題。當傳入的任務速率大于系統處理能力時,數據處理將會對未處理數據產生一個緩沖區。
與此同時,我們還與Akka團隊的高級開發人員Konrad Malawski進行了溝通,他是Reactive Streams計劃的***,解釋了Reactive Streams的重要性以及如何使用。
Oracle指出,新的增強將包括“一個很小的接口,其定義符合(來自Reactive Stream initiative的)廣泛參與”,這就是Flow類的來源。
Reactive Streams由4個Java接口構成:
處理器(Processor)
發布商(Publisher)
訂閱用戶(Subscriber)
訂閱(Subscription)
Flow類允許相互關聯的接口和靜態方法來建立流控制組件,其中發布者產生由一個或多個訂閱者消費的項目,每個訂閱者由訂閱管理。
Reactive Streams構建在java.util.concurrent.Flow容器對象下,開發者可以在這里找到Flow.Publisher,一個用作lambda表達式或方法引用的賦值目標功能接口。該接口可以讓開發者更容易生成Flow.Subscription元素,并且將它們鏈接在一起。
另一個元素Flow.Subscriber,是異步工作機制,由請求觸發。它可以從Flow.Subscription請求多個元素,開發者還可以根據需要自定義緩沖區大小。
這些接口適用于并發和分布式異步設置,它們之間的通信依賴于一種簡單的流控制形式,可用于避免資源管理問題。
感興趣的用戶可以在java.util.concurrent.Flow下面查看代碼示例。
目前已有一些第三方庫實現了Reactive Streams接口,你無需等到Java 9發布便可嘗試一下。
CompletableFuture新特性
Java 8引進了CompletableFuture,繼承自Future<T>。Futures是非常有用的,當我們不希望或者不需要一個直接計算結果的時候,我們會收到一個Future對象來保存計算完成時分配的實際結果。通過調用complete()方法并且無需異步等待即可顯式完成。它還允許在一系列操作中構建管道數據流程。
這樣,任何類型的可用值都可以在Future中使用默認返回值,即使計算沒有完成。這也將成為CompletableFuture提案更新的一部分,包括延遲和超時、更好地支持子類化和一些實用方法。“Java9的基本功能有哪些”的內容就介紹到這里了,感謝大家的閱讀。如果想了解更多行業相關的知識可以關注億速云網站,小編將為大家輸出更多高質量的實用文章!
免責聲明:本站發布的內容(圖片、視頻和文字)以原創、轉載和分享為主,文章觀點不代表本網站立場,如果涉及侵權請聯系站長郵箱:is@yisu.com進行舉報,并提供相關證據,一經查實,將立刻刪除涉嫌侵權內容。