使用 Java Future 解鎖更快的非同步編程

在上一篇文章中，我們探討了 ListenableFuture 的世界。現在，讓我們更深入地研究更高級的技術，特別關注轉換和連結。想像一下，我們有一個從非同步服務取得的 ListenableFuture。另外，我們還有一個簡單的方法：

Document parse(String xml) {//...

我們不需要使用字串本身，而是需要文件。一種方法是解析 Future 並處理字串。然而，一個更優雅的解決方案是在結果可用後應用轉換，使我們的方法表現得好像它總是返回 ListenableFuture。這非常簡單：

final ListenableFuture future = //...
 
final ListenableFuture documentFuture = Futures.transform(future, new Function() {
    @override    public Document apply(String contents) {
        return parse(contents);
    }
});

或者，為了更好的可讀性：

final Function parseFun = new Function() {
    @override    public Document apply(String contents) {
        return parse(contents);
    }
};
 
final ListenableFuture future = //...
 
final ListenableFuture documentFuture = Futures.transform(future, parseFun);

雖然 Java 語法可能有其局限性，但讓我們專注於我們已經取得的成就。 Futures.transform() 不會等待底層 ListenableFuture 應用 parse() 轉換。相反，它註冊一個回調，準備在給定的 future 完成時收到通知。這種轉變在適當的時刻為我們動態且透明地應用。我們仍然有一個未來，但這次包裝了一個文件。

現在，讓我們更進一步。我們還有一個非同步的、可能需要長時間運行的方法來計算給定文件的相關性（無論這在上下文中意味著什麼）：

ListenableFuture calculateRelevance(Document pageContents) {//...

我們能以某種方式將它與我們已經擁有的 ListenableFuture 連結起來嗎？第一次嘗試：

final Function> relevanceFun = new Function>() {
    @override    public ListenableFuture apply(Document input) {
        return calculateRelevance(input);
    }
};
 
final ListenableFuture future = //...
final ListenableFuture documentFuture = Futures.transform(future, parseFun);
final ListenableFuture> relevanceFuture = Futures.transform(documentFuture, relevanceFun);

有關增強非同步程式設計可能性的更多信息，請訪問此連結。

以上是使用 Java Future 解鎖更快的非同步編程的詳細內容。更多資訊請關注PHP中文網其他相關文章！