在Java的非同步程式設計中,CompletableFuture是一個很有用的類,它可以幫助我們在非同步操作完成之後進行回調,並且有很好的異常處理機制。本文將介紹如何使用CompletableFuture的whenComplete和exceptionally函式進行例外處理。
CompletableFuture的whenComplete函數是一個回呼函數,當非同步操作完成之後,它會被呼叫。當非同步操作正常完成時,當Complete的第一個參數是非同步操作的結果,我們可以在回調函數中對結果進行操作。當非同步操作失敗時,它會將異常作為whenComplete的第二個參數傳遞給回調函數。
範例程式碼:
CompletableFuture<String> future = CompletableFuture.supplyAsync(() -> { return "hello world"; }); future.whenComplete((result, throwable) -> { if (throwable == null) { System.out.println("result: " + result); } else { System.out.println("exception: " + throwable.getMessage()); } });
在上面的程式碼中,我們首先建立了一個CompletableFuture實例,並使用supplyAsync方法非同步執行了一個任務,這個任務傳回了一個字串"hello world "。我們使用whenComplete函數作為回調函數,在非同步操作完成之後進行處理。如果非同步操作正常完成,我們列印出結果;如果非同步操作失敗,我們列印出異常的資訊。
CompletableFuture的exceptionally函數也是一個回呼函數,但是它只會在非同步操作出現異常時被呼叫。它的傳回值是一個新的CompletableFuture實例,用來處理異常的情況。我們可以在exceptionally函數中對異常進行處理,並傳回一個預設值或其他的值。
範例程式碼:
CompletableFuture<String> future = CompletableFuture.supplyAsync(() -> { throw new RuntimeException("exception occurred"); }); CompletableFuture<String> result = future.exceptionally(throwable -> { return "default value"; }); result.whenComplete((value, throwable) -> { if (throwable == null) { System.out.println("result: " + value); } else { System.out.println("exception: " + throwable.getMessage()); } });
在上面的程式碼中,我們使用了supplyAsync方法執行一個會拋出例外的任務。我們使用exceptionally函數來處理異常情況,它的回傳值是一個新的CompletableFuture實例。在回調函數中,我們可以對結果進行處理。如果異常沒有被捕獲,我們將列印出異常訊息;如果異常被捕獲並處理,我們將列印出傳回的預設值。
總結
本文介紹如何使用CompletableFuture的whenComplete和exceptionally函式進行例外處理。使用CompletableFuture的非同步回呼函數和異常處理機制可以大幅提高Java的非同步程式設計效率和可靠性。
以上是Java中如何使用CompletableFuture的whenComplete和exceptionally函式進行例外處理的詳細內容。更多資訊請關注PHP中文網其他相關文章!