java異步結(jié)果不阻塞怎么實(shí)現(xiàn)

204次閱讀

共計(jì) 690 個(gè)字符，預(yù)計(jì)需要花費(fèi) 2 分鐘才能閱讀完成。

在 Java 中，可以使用多線程或者回調(diào)函數(shù)來實(shí)現(xiàn)異步結(jié)果不阻塞的效果。

使用多線程：創(chuàng)建一個(gè)新的線程來執(zhí)行耗時(shí)的任務(wù)，然后繼續(xù)執(zhí)行后續(xù)的代碼，不阻塞主線程。可以使用 Java 的 Thread 類或者 ExecutorService 來創(chuàng)建和管理線程。

new Thread(() -> {// 執(zhí)行耗時(shí)的任務(wù) 
    String result = longRunningTask();
    
    // 將結(jié)果傳遞給后續(xù)的代碼，可以使用回調(diào)函數(shù)或者消息隊(duì)列等機(jī)制 
    callback(result);
}).start();

// 主線程繼續(xù)執(zhí)行后續(xù)的代碼 
otherCode();

使用回調(diào)函數(shù)：定義一個(gè)接口或者函數(shù)，將耗時(shí)任務(wù)的結(jié)果作為參數(shù)傳遞給回調(diào)函數(shù)，在回調(diào)函數(shù)中處理結(jié)果。可以使用 Lambda 表達(dá)式簡(jiǎn)化代碼。

public interface TaskCallback {void onResult(String result);
}

public void longRunningTask(TaskCallback callback) {new Thread(() -> {// 執(zhí)行耗時(shí)的任務(wù) 
        String result = longRunningTask();
        
        // 調(diào)用回調(diào)函數(shù)處理結(jié)果 
        callback.onResult(result);
    }).start();}

// 調(diào)用異步任務(wù) 
longRunningTask(result -> {// 處理結(jié)果 
    System.out.println(result);
});

// 主線程繼續(xù)執(zhí)行后續(xù)的代碼 
otherCode();