文章來源:程序員知識碼頭
有想了解更多相關知識的也可以私信小編
本文主要介紹了JAVA中的回調機制,以及Java多線程中類似回調的機制。
模塊間的調用
在一個應用系統中,無論使用何種語言開發,必然存在模塊之間的調用,調用的方式分為幾種:
(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); }