电脑知识|欧美黑人一区二区三区|软件|欧美黑人一级爽快片淫片高清|系统|欧美黑人狂野猛交老妇|数据库|服务器|编程开发|网络运营|知识问答|技术教程文章 - 好吧啦网

您的位置:首頁技術文章
文章詳情頁

兩個例子了解java中的回調機制

瀏覽:41日期:2022-08-17 08:04:19
前言

先讓我們通過一個生活中的場景來還原一下回調的場景:你遇到了一個技術難題(比如,1+1等于幾?太難了!),于是你去咨詢大牛,大牛說現在正在忙,待會兒告訴你結果。

此時,你可能會去刷朋友圈了,等大牛忙完之后,告訴你答案是2。

那么,這個過程中詢問問題(調用對方接口),然后問題解決之后再告訴你(對方處理完再調用你,通知結果),這一過程便是回調。

系統調用的分類

應用系統模塊之間的調用,通常分為:同步調用,異步調用,回調。

兩個例子了解java中的回調機制

同步調用是最基本的調用方式。類A的a()方法調用類B的b()方法,類A的方法需要等到B類的方法執行完成才會繼續執行。如果B的方法長時間阻塞,就會導致A類方法無法正常執行下去。

兩個例子了解java中的回調機制

如果A調用B,B的執行時間比較長,那么就需要考慮進行異步處理,使得B的執行不影響A。通常在A中新起一個線程用來調用B,然后A中的代碼繼續執行。

異步通常分兩種情況:第一,不需要調用結果,直接調用即可,比如發送消息通知;第二,需要異步調用結果,在Java中可使用Future+Callable實現。

兩個例子了解java中的回調機制

通過上圖我們可以看到回到屬于一種雙向的調用方式。回調的基本上思路是:A調用B,B處理完之后再調用A提供的回調方法(通常為callbakc())通知結果。

通常回調分為:同步回調和異步回調。網絡上大多數的回調案例都是同步回調。

其中同步回調與同步調用類似,代碼運行到某一個位置的時候,如果遇到了需要回調的代碼,會在這里等待,等待回調結果返回后再繼續執行。

而異步回調與異步調用類似,代碼執行到需要回調的代碼的時候,并不會停下來,而是繼續執行,當然可能過一會回調的結果會返回回來。

同步回調實例

下面我們以同步回調為例來講解回調的Java代碼實現。整個過程就模擬上面問答問題的場景。

首先,定義給一個CallBack的接口,將回調的功能進行單獨抽離:

public interface CallBack { void callback(String string);}

CallBack接口中提供了一個callback方法,用于回調時調用。

然后定義問問題的人Person:

public class Person implements CallBack { private Genius genius; public Person(Genius genius) {this.genius = genius; } @Override public void callback(String string) {System.out.println('收到答案:' + string); } public void ask() {genius.answer(this); }}

由于Person要提供回調方法,因此實現CallBack接口及其方法,方法中主要針對回調結果進行處理。

同時,由于Person要調用Genius對應的方法,因此要持有Genius的引用,這里通過構造方法傳入。

定義回答問題的大神Genius類:

public class Genius { public void answer(CallBack callBack) {System.out.println('在忙其他事...');try { Thread.sleep(2000); System.out.println('忙完其他事,開始計算...');} catch (InterruptedException e) { e.printStackTrace();}System.out.println('天才計算出答案為:2');// 回調告訴你callBack.callback('2'); }}

這模擬大神正在忙碌,線程睡眠2秒,忙碌完之后,開始幫忙計算答案,獲得答案之后,調用CallBack接口的callback方法進行回調,通知結果。

通過Main方法進行測試:

public static void main(String[] args) { Genius genius = new Genius(); Person you = new Person(genius); you.ask();}

執行打印結果如下:

在忙其他事...忙完其他事,開始計算...天才計算出答案為:2收到答案:2

上面的過程,就實現了一個同步回調的功能。當然,從程序設計上來說,可以對Person和Genius進一步抽象化處理,通過接口的形式呈現。

在上述回調機制的代碼實現中,最核心的是在調用answer方法時傳遞了this參數,即調用者自身。

從本質上來說,回調是一種思想,是一種機制,至于具體如何實現,如何通過代碼將回調實現得優雅、實現得可擴展性比較高,就需要八仙過海各顯神通了。

異步回調實例

上面的實例演示了同步回調,很明顯在調用的過受到Genius執行時長的影響,需要等到Genius處理完才能繼續執行Person方法中的后續代碼。

下面在上述示例上進行改進,Person提供一個支持異步回調的方法:

public void askASyn() { System.out.println('創建新線程請教問題'); new Thread(() -> genius.answer(this)).start(); System.out.println('新線程已啟動...');}

在該方法內,新建了一個線程用來處理Genius#answer方法的調用,這樣就能夠跳過Genius#answer方法的阻塞,直接執行下面的操作(日志打印)。

在main方法中將調用的方法改為askASyn,打印結果如下:

創建新線程請教問題新線程已啟動...在忙其他事...忙完其他事,開始計算...天才計算出答案為:2收到答案:2

可以看出,直接打印了“新線程已啟動...”,后續才打印出Genius#answer方法方法中處理日志和回調時callback方法接收到的信息。

基于Future的半異步

除了上述的同步,異步處理,還有一種介于同步和異步之間的基于Future的半異步處理。

在Java使用nio后無法立即拿到真實的數據,而是先得到一個'future',可以理解為郵戳或快遞單,為了獲悉真正的數據我們需要不停的通過快遞單號'future'查詢快遞是否真正寄到。

Futures是一個抽象的概念,它表示一個值,在某一點會變得可用。一個Future要么獲得計算完的結果,要么獲得計算失敗后的異常。

通常什么時候會用到Future呢?一般來說,當執行一個耗時的任務時,使用Future就可以讓線程暫時去處理其他的任務,等長任務執行完畢再返回其結果。

經常會使用到Future的場景有:1. 計算密集場景。2. 處理大數據量。3. 遠程方法調用等。

Java在java.util.concurrent包中附帶了Future接口,它使用Executor異步執行。

例如下面的代碼,每傳遞一個Runnable對象到ExecutorService.submit()方法就會得到一個回調的Future,使用它檢測是否執行,這種方法可以是同步等待線處理結果完成。

public class TestFuture { public static void main(String[] args) {//實現一個Callable接口Callable<User> c = () -> { //這里是業務邏輯處理 //讓當前線程阻塞1秒看下效果 Thread.sleep(1000); return new User('張三');};ExecutorService es = Executors.newFixedThreadPool(2);// 記得要用submit,執行Callable對象Future<User> fn = es.submit(c);// 一定要調用這個方法,不然executorService.isTerminated()永遠不為truees.shutdown();// 無限循環等待任務處理完畢 如果已經處理完畢 isDone返回truewhile (!fn.isDone()) { try {//處理完畢后返回的結果User nt = fn.get();System.out.println(nt.name); } catch (InterruptedException | ExecutionException e) {e.printStackTrace(); }} } static class User {private String name;private User(String name) { this.name = name;} }}

此種情況下雖然是創建了新線程來進行處理,但還是需要等待處理的結果。好處是可以將批量的處理,分為幾個線程同時進行處理,最后對結果進行合并,達到提升處理效率的目的。

小結

經過這篇文章,想必大家對Java的回調機制已經有所了解,在各類開源框架中,其實也會經常看到回調的使用,活學活用。

以上就是兩個例子了解java中的回調機制的詳細內容,更多關于Java 回調機制的資料請關注好吧啦網其它相關文章!

標簽: Java
相關文章:
主站蜘蛛池模板: 钢格板|热镀锌钢格板|钢格栅板|钢格栅|格栅板-安平县昊泽丝网制品有限公司 | 滑板场地施工_极限运动场地设计_滑板公园建造_盐城天人极限运动场地建设有限公司 | 防渗土工膜|污水处理防渗膜|垃圾填埋场防渗膜-泰安佳路通工程材料有限公司 | 泰国试管婴儿_泰国第三代试管婴儿_泰国试管婴儿费用/多少钱_孕泰来 | 蒸汽吸附分析仪-进口水分活度仪|康宝百科 | 硬齿面减速机_厂家-山东安吉富传动设备股份有限公司 | 全自动面膜机_面膜折叠机价格_面膜灌装机定制_高速折棉机厂家-深圳市益豪科技有限公司 | 南京蜂窝纸箱_南京木托盘_南京纸托盘-南京博恒包装有限公司 | 网站建设_网站制作_SEO优化推广_百度推广开户_朋友圈网络科技 | 精密五金加工厂-CNC数控车床加工_冲压件|蜗杆|螺杆加工「新锦泰」 | 企业管理培训,企业培训公开课,企业内训课程,企业培训师 - 名课堂企业管理培训网 | 酒瓶_酒杯_玻璃瓶生产厂家_徐州明政玻璃制品有限公司 | 电销卡_北京电销卡_包月电话卡-豪付网络 | 钛板_钛管_钛棒_钛盘管-无锡市盛钛科技有限公司 | 济南品牌包装设计公司_济南VI标志设计公司_山东锐尚文化传播 | 氧化锆陶瓷_氧化锆陶瓷加工_氧化锆陶瓷生产厂家-康柏工业陶瓷有限公司 | 商标转让-商标注册-商标查询-软著专利服务平台 - 赣江万网 | NM-02立式吸污机_ZHCS-02软轴刷_二合一吸刷软轴刷-厦门地坤科技有限公司 | 宜兴紫砂壶知识分享 - 宜兴壶人 医用空气消毒机-医用管路消毒机-工作服消毒柜-成都三康王 | 网站优化公司_北京网站优化_抖音短视频代运营_抖音关键词seo优化排名-通则达网络 | 阜阳在线-阜阳综合门户 | 钢托盘,钢制托盘,立库钢托盘,金属托盘制造商_南京飞天金属制品实业有限公司 | 防爆型气象站_农业气象站_校园气象站_农业四情监测系统「山东万象环境科技有限公司」 | VI设计-LOGO设计公司-品牌设计公司-包装设计公司-导视设计-杭州易象设计 | 学校用栓剂模,玻璃瓶轧盖钳,小型安瓿熔封机,实验室安瓿熔封机-长沙中亚制药设备有限公司 | 一点车讯-汽车网站,每天一点最新车讯! | 光照全温振荡器(智能型)-恒隆仪器| 汕头市盛大文化传播有限公司,www.11400.cc | 隔离变压器-伺服变压器--输入输出电抗器-深圳市德而沃电气有限公司 | TPE塑胶原料-PPA|杜邦pom工程塑料、PPSU|PCTG材料、PC/PBT价格-悦诚塑胶 | 德国进口电锅炉_商用电热水器_壁挂炉_电采暖器_电热锅炉[德国宝] | 制冷采购电子商务平台——制冷大市场 | 全自动变压器变比组别测试仪-手持式直流电阻测试仪-上海来扬电气 | 蒸汽热收缩机_蒸汽发生器_塑封机_包膜机_封切收缩机_热收缩包装机_真空机_全自动打包机_捆扎机_封箱机-东莞市中堡智能科技有限公司 | 成都离婚律师|成都结婚律师|成都离婚财产分割律师|成都律师-成都离婚律师网 | 六维力传感器_六分量力传感器_模腔压力传感器-南京数智微传感科技有限公司 | 二手注塑机回收_旧注塑机回收_二手注塑机买卖 - 大鑫二手注塑机 二手光谱仪维修-德国OBLF光谱仪|进口斯派克光谱仪-热电ARL光谱仪-意大利GNR光谱仪-永晖检测 | 广州物流公司_广州货运公司_广州回程车运输 - 万信物流 | 蔡司三坐标-影像测量机-3D扫描仪-蔡司显微镜-扫描电镜-工业CT-ZEISS授权代理商三本工业测量 | TPU薄膜_TPU薄膜生产厂家_TPU热熔胶膜厂家定制_鑫亘环保科技(深圳)有限公司 | SMC-SMC电磁阀-日本SMC气缸-SMC气动元件展示网 |