更多內容請關注微信公眾號【Java技術江湖】

景泰網站制作公司哪家好，找創新互聯！從網頁設計、網站建設、微信開發、APP開發、成都響應式網站建設公司等網站項目制作，到程序開發，運營維護。創新互聯于2013年創立到現在10年的時間，我們擁有了豐富的建站經驗和運維經驗，來保證我們的工作的順利進行。專注于網站建設就選創新互聯。

這是一位阿里 Java 工程師的技術小站，作者黃小斜，專注 Java 相關技術：SSM、SpringBoot、MySQL、分布式、中間件、集群、Linux、網絡、多線程，偶爾講點Docker、ELK，同時也分享技術干貨和學習經驗，致力于Java全棧開發！（關注公眾號后回復”資料“即可領取 3T 免費技術學習資源以及我我原創的程序員校招指南、Java學習指南等資源）

cdn.xitu.io/2019/4/6/169f1735fd0d1d16?w=900&h=500&f=jpeg&s=109856">

本文主要介紹了Java中的回調機制，以及Java多線程中類似回調的機制。

具體代碼在我的GitHub中可以找到

https://github.com/h3pl/MyTech

文章首發于我的個人博客：

https://h3pl.github.io/2018/04/26/javase9

更多關于Java后端學習的內容請到我的CSDN博客上查看： https://blog.csdn.net/a724888

模塊間的調用

本部分摘自https://www.cnblogs.com/xrq730/p/6424471.html

在一個應用系統中，無論使用何種語言開發，必然存在模塊之間的調用，調用的方式分為幾種：

（1）同步調用

同步調用是最基本并且最簡單的一種調用方式，類A的方法a()調用類B的方法b()，一直等待b()方法執行完畢，a()方法繼續往下走。這種調用方式適用于方法b()執行時間不長的情況，因為b()方法執行時間一長或者直接阻塞的話，a()方法的余下代碼是無法執行下去的，這樣會造成整個流程的阻塞。

（2）異步調用

異步調用是為了解決同步調用可能出現阻塞，導致整個流程卡住而產生的一種調用方式。類A的方法方法a()通過新起線程的方式調用類B的方法b()，代碼接著直接往下執行，這樣無論方法b()執行時間多久，都不會阻塞住方法a()的執行。

但是這種方式，由于方法a()不等待方法b()的執行完成，在方法a()需要方法b()執行結果的情況下（視具體業務而定，有些業務比如啟異步線程發個微信通知、刷新一個緩存這種就沒必要），必須通過一定的方式對方法b()的執行結果進行監聽。

在Java中，可以使用Future+Callable的方式做到這一點，具體做法可以參見我的這篇文章Java多線程21：多線程下其他組件之CyclicBarrier、Callable、Future和FutureTask。

（3）回調

最后是回調，回調的思想是：

類A的a()方法調用類B的b()方法 類B的b()方法執行完畢主動調用類A的callback()方法 這樣一種調用方式組成了上圖，也就是一種雙向的調用方式。

回調實例：Tom做題

數學老師讓Tom做一道題，并且Tom做題期間數學老師不用盯著Tom，而是在玩手機，等Tom把題目做完后再把答案告訴老師。

1 數學老師需要Tom的一個引用，然后才能將題目發給Tom。

2 數學老師需要提供一個方法以便Tom做完題目以后能夠將答案告訴他。

3 Tom需要數學老師的一個引用，以便Tom把答案給這位老師，而不是隔壁的體育老師。

回調接口，可以理解為老師接口

    //回調指的是A調用B來做一件事，B做完以后將結果告訴給A，這期間A可以做別的事情。
    //這個接口中有一個方法，意為B做完題目后告訴A時使用的方法。
    //所以我們必須提供這個接口以便讓B來回調。
    //回調接口，
    public interface CallBack {
        void tellAnswer(int res);
    }

數學老師類

    //老師類實例化回調接口，即學生寫完題目之后通過老師的提供的方法進行回調。
    //那么學生如何調用到老師的方法呢，只要在學生類的方法中傳入老師的引用即可。
    //而老師需要指定學生答題，所以也要傳入學生的實例。
public class Teacher implements CallBack{
    private Student student;
    Teacher(Student student) {
        this.student = student;
    }
    void askProblem (Student student, Teacher teacher) {
        //main方法是主線程運行，為了實現異步回調，這里開啟一個線程來操作
        new Thread(new Runnable() {
            @Override
            public void run() {
                student.resolveProblem(teacher);
            }
        }).start();
        //老師讓學生做題以后，等待學生回答的這段時間，可以做別的事，比如玩手機.\
        //而不需要同步等待，這就是回調的好處。
        //當然你可以說開啟一個線程讓學生做題就行了，但是這樣無法讓學生通知老師。
        //需要另外的機制去實現通知過程。
        // 當然，多線程中的future和callable也可以實現數據獲取的功能。
        for (int i = 1;i < 4;i ++) {
            System.out.println("等學生回答問題的時候老師玩了 " + i + "秒的手機");
        }
    }
    @Override
    public void tellAnswer(int res) {
        System.out.println("the answer is " + res);
    }
}

學生接口

    //學生的接口，解決問題的方法中要傳入老師的引用，否則無法完成對具體實例的回調。
    //寫為接口的好處就是，很多個學生都可以實現這個接口，并且老師在提問題時可以通過
    //傳入List<Student>來聚合學生，十分方便。
public interface Student {
    void resolveProblem (Teacher teacher);
}

學生Tom

public class Tom implements Student{
    @Override
    public void resolveProblem(Teacher teacher) {
        try {
            //學生思考了3秒后得到了答案，通過老師提供的回調方法告訴老師。
            Thread.sleep(3000);
            System.out.println("work out");
            teacher.tellAnswer(111);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }

測試類

public class Test {
    public static void main(String[] args) {
        //測試
        Student tom = new Tom();
        Teacher lee = new Teacher(tom);
        lee.askProblem(tom, lee);
        //結果
//        等學生回答問題的時候老師玩了 1秒的手機
//        等學生回答問題的時候老師玩了 2秒的手機
//        等學生回答問題的時候老師玩了 3秒的手機
//        work out
//        the answer is 111
    }
}

多線程中的“回調”

Java多線程中可以通過callable和future或futuretask結合來獲取線程執行后的返回值。實現方法是通過get方法來調用callable的call方法獲取返回值。

其實這種方法本質上不是回調，回調要求的是任務完成以后被調用者主動回調調用者的接口。而這里是調用者主動使用get方法阻塞獲取返回值。

public class 多線程中的回調 {
    //這里簡單地使用future和callable實現了線程執行完后
    public static void main(String[] args) throws ExecutionException, InterruptedException {
        ExecutorService executor = Executors.newCachedThreadPool();
        Future<String> future = executor.submit(new Callable<String>() {
            @Override
            public String call() throws Exception {
                System.out.println("call");
                TimeUnit.SECONDS.sleep(1);
                return "str";
            }
        });
        //手動阻塞調用get通過call方法獲得返回值。
        System.out.println(future.get());
        //需要手動關閉，不然線程池的線程會繼續執行。
        executor.shutdown();
    //使用futuretask同時作為線程執行單元和數據請求單元。
    FutureTask<Integer> futureTask = new FutureTask(new Callable<Integer>() {
        @Override
        public Integer call() throws Exception {
            System.out.println("dasds");
            return new Random().nextInt();
        }
    });
    new Thread(futureTask).start();
    //阻塞獲取返回值
    System.out.println(futureTask.get());
}
@Test
public void test () {
    Callable callable = new Callable() {
        @Override
        public Object call() throws Exception {
            return null;
        }
    };
    FutureTask futureTask = new FutureTask(callable);
}
}

網站題目：Java基礎9：解讀Java回調機制
文章源于：http://www.js-pz168.com/article48/jipohp.html

成都網站建設公司_創新互聯，為您提供App設計、網站收錄、品牌網站制作、App開發、面包屑導航、網站制作

廣告

聲明：本網站發布的內容（圖片、視頻和文字）以用戶投稿、用戶轉載內容為主，如果涉及侵權請盡快告知，我們將會在第一時間刪除。文章觀點不代表本網站立場，如需處理請聯系客服。電話：028-86922220；郵箱：631063699@qq.com。內容未經允許不得轉載，或轉載時需注明來源： 創新互聯