更多內容請關注微信公眾號【Java技術江湖】
這是一位阿里 Java 工程師的技術小站，作者黃小斜，專注 Java 相關技術：SSM、SpringBoot、MySQL、分布式、中間件、集群、Linux、網絡、多線程，偶爾講點Docker、ELK，同時也分享技術干貨和學習經驗，致力於Java全棧開發！（關注公眾號后回復”資料“即可領取 3T 免費技術學習資源以及我我原創的程序員校招指南、Java學習指南等資源）
本文主要介紹了Java中的回調機制，以及Java多線程中類似回調的機制。
具體代碼在我的GitHub中可以找到
https://github.com/h2pl/MyTech
文章首發於我的個人博客：
https://h2pl.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);
}
}