Java多線程回調

引自：java多線程回調方法

下面看一個實際例子來理解：

本示例設置一個提問者，一個回答者，而回答者需要回答提問者一個很深奧的問題時，這時需要很多時間去查找，提問者又開始做其他的事情，

等回答者找到答案后，再把答案告訴提問者

一.提問者的類

涉及到長時間的思考，要sleep，要繼承Thread

package com.xykj.thread;
public class XiaoZhang extends Thread {
    // 回答1+1，很簡單的問題不需要線程
    public int add(int num1, int num2) {
       return num1 + num2;
    }
 
    // 重寫run方法
    @Override
    public void run() {
       // 回答地球為什么是圓的
       askquestion();
       super.run();
    }
 
    // 回調接口的創建，里面要有一個回調方法
    //回調接口什么時候用呢？這個思路是最重要的
    //
   
    public static interface CallPhone {
       public void call(String question);
    }
 
    // 回調接口的對象
    CallPhone callPhone;
 
    // 回答地球為什么是圓的
    private void askquestion() {
       System.err.println("開始查找資料！");
       try {
           sleep(3000);// 思考3天
       } catch (InterruptedException e) {
           e.printStackTrace();
       }
       // 把答案返回到回調接口的call方法里面
       if (callPhone!=null) {//提問者實例化callPhone對象，相當於提問者已經告訴我，我到時用什么方式回復答案
           //這個接口的方法實現是在提問者的類里面
           callPhone.call("知道了，！！！~~~~百度有啊");
       }     
    }
}

二．提問者的類

package com.xykj.thread;
import com.xykj.thread.XiaoZhang.CallPhone;
public class MainClass {
    /**
     * java回調方法的使用
     * 實際操作時的步驟：（以本實例解釋）
     * 1.在回答者的類內創建回調的接口
     * 2.在回答者的類內創建回調接口的對象，
     * 3.在提問者類里面實例化接口對象，重寫接口方法
     * 2.-3.這個點很重要，回調對象的實例化，要在提問者的類內實例化，然后重寫接口的方法
     * 相當於提問者先把一個聯絡方式給回答者，回答者找到答案后，通過固定的聯絡方式，來告訴提問者答案。
     * 4.調用開始新線程的start方法
     * 5.原來的提問者還可以做自己的事
     * */
    public static void main(String[] args) {
       // 小王問小張1+1=？，線程同步
       XiaoZhang xiaoZhang = new XiaoZhang();
       int i = xiaoZhang.add(1, 1);//回答1+1的答案
 
       // 問小張地球為什么是圓的？回調方法的使用
       //這相當於先定好一個返答案的方式，再來執行實際操作
      
       // 實例化回調接口的對象
       CallPhone phone = new CallPhone() {
           @Override
           public void call(String question) {
              //回答問題者，回答后，才能輸出答案
              System.err.println(question);
           }
       };
      
       //把回調對象賦值給回答者的回調對象，回答問題者的回調對象才能回答問題
       xiaoZhang.callPhone = phone;
      
       System.out.println("交代完畢！");
       //相關交代完畢之后再執行查詢操作
       xiaoZhang.start();
      
       //小王做自己的事！
       System.out.println("小王做自己的事！");
    }
 
}

運行結果

肯定是要提問者先交代完回答者怎樣的方式回答問題，

然后提問者再做自己的事，回答者開始思考答案。

這里交代聯絡方式具體表現就是在提問者的類里面實例化回調接口和實現回答的方法。

 

補充：

實際業務中，通常是需要返回確定的值，如controller返回web，里面涉及另起線程，做別的操作，比如，主業務是審核，子線程是預警，預警信息會在復核時顯示。上述改進便在返回信息做入庫操作；另一種方案是在controller或service里，另起線程池，直接操作業務方法，然后自定義子線程執行狀態。