快捷導(dǎo)航

Java中的異步回調(diào)問題

更新時間：2023年12月20日 08:44:07 作者：bat在等我

這篇文章主要介紹了Java中的異步回調(diào)問題,具有很好的參考價值,希望對大家有所幫助,如有錯誤或未考慮完全的地方,望不吝賜教

1. 異步回調(diào)

直接上代碼，固定格式：主業(yè)務(wù)代碼和一個處理結(jié)果的接口

/**
 * Callback
 * 回調(diào)一般是異步處理的一種技術(shù)。
 * 一個回調(diào)是被傳遞到并且執(zhí)行完該方法。 這種方式只能異步回調(diào)，
 * 如果需要同步等待線程處理結(jié)果可以使用下面介紹的Futures
 */
interface MyCallback {

    void doCallback(Map<String, Object> params);
}

public class TestAsyncCallBack {

    static ExecutorService es = Executors.newFixedThreadPool(2);

    public static void doSomething(MyCallback callback) {
        // 初始化一個線程  
        Thread t = new Thread() {
            public void run() {

                // 這里是業(yè)務(wù)邏輯處理  
                System.out.println("子線任務(wù)開始執(zhí)行:" + Thread.currentThread().getId());
                // 為了能看出效果 ，讓當(dāng)前線程阻塞5秒  
                try {
                    Thread.sleep(5000);
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
                System.out.println("子線任務(wù)結(jié)束執(zhí)行:");
                // 處理完業(yè)務(wù)邏輯，  
                Map<String, Object> params = new HashMap<String, Object>();
                params.put("a1", "子線程處理結(jié)果");
                callback.doCallback(params);
            }
        };
        es.execute(t);
        //一定要調(diào)用這個方法，不然executorService.isTerminated()永遠不為true
        es.shutdown();
    }

    public static void main(String[] args) {
        // 內(nèi)部類 等價于 new MyCallBack(){...}, 主要作用就是重寫doCallback方法
        doSomething((params) -> {
            System.out.println("單個線程也已經(jīng)處理完畢了，返回參數(shù)a1=" + params.get("a1"));
        });

        System.out.println("主線任務(wù)已經(jīng)執(zhí)行完了:" + Thread.currentThread().getId());
    }
}

2. 使用Future同步等待執(zhí)行結(jié)果

主要是利用了Callable接口開啟進行多線程，call方法可以返回結(jié)果

/**
 * Futures是一個抽象的概念，它表示一個值，該值可能在某一點變得可用。一個Future要么獲得計算完的結(jié)果，要么獲得計算失敗后的異常
 * 每傳遞一個Runnable對象到ExecutorService.submit()方法就會得到一個回調(diào)的Future,你能使用它檢測是否執(zhí)行，這種方法可以是同步等待線處理結(jié)果
 */
public class TestFuture {
    public static void main(String[] args) {
        Callable<Result> callable = new Callable<Result>() {
            @Override
            public Result call() throws Exception {
                //這里是業(yè)務(wù)邏輯處理
                //讓當(dāng)前線程阻塞1秒看下效果
                Thread.sleep(5000);
                return new Result("張三");
            }
        };
        ExecutorService executorService = Executors.newFixedThreadPool(5);

        Future<Result> resultFuture = executorService.submit(callable);
        executorService.shutdown();

        /**
         * 無限循環(huán)等待任務(wù)處理完畢  如果已經(jīng)處理完畢 isDone返回true
         */
        while (!resultFuture.isDone()) {
            try {
                Result result = resultFuture.get(); // 在這一步阻塞知直到得到子線程返回結(jié)果
                System.out.println(result.getName());
            } catch (InterruptedException e) {
                e.printStackTrace();
            } catch (ExecutionException e) {
                e.printStackTrace();
            }
        }
    }
}

class Result {

    private String name;

    public Result(String name) {
        this.name = name;
    }

    public String getName() {
        return name;
    }
}