今天聽(tīng)說(shuō)了騰訊一個(gè)很牛逼的技術(shù), 求問(wèn)是怎么實(shí)現(xiàn)的

csumck

聽(tīng)說(shuō)他們有個(gè)庫(kù)可以很方便的把阻塞接口的調(diào)用替換成異步接口調(diào)用的代碼.
比如有段阻塞式的查詢代碼是如下這樣的:

1. 
   
2. get_request();//獲取請(qǐng)求
   
3. do_blocked_query();//調(diào)用阻塞接口進(jìn)行查詢
   
4. reply();//給出響應(yīng)
   

復(fù)制代碼

使用了他這個(gè)庫(kù)后,代碼變成類似這樣:

1. 
   
2. get_request();//獲取請(qǐng)求
   
3. do_nonblock_query();//調(diào)用異步接口進(jìn)行查詢
   
4. reply();//給出響應(yīng)
   

復(fù)制代碼

神奇的是, 只是調(diào)用的接口換成了異步接口, 其他代碼沒(méi)什么變化, 整個(gè)代碼看上去還是順序執(zhí)行的.
這種是怎么實(shí)現(xiàn)的? 難道異步接口里保存了調(diào)用棧之類的東西, 所以操作完成后可以回到以前的代碼里順序執(zhí)行?

這種玩意有沒(méi)有開(kāi)源實(shí)現(xiàn)的?

cobras

如果是我，我會(huì)如此實(shí)現(xiàn)非阻塞：
將函數(shù)轉(zhuǎn)換為命令，排入核心中的命令隊(duì)列中。由核心按照命令隊(duì)列依次運(yùn)行，并保存結(jié)果，發(fā)送通知消息。

csumck

回復(fù) 2# cobras


    你說(shuō)的這個(gè)方法很好, 沒(méi)問(wèn)題的.
    我想問(wèn)的是騰訊這個(gè)是怎么實(shí)現(xiàn)的, 這種實(shí)現(xiàn)讓調(diào)用者可以用同步的代碼寫(xiě)出異步的效果, 用起來(lái)相當(dāng)舒服.

cobras

你沒(méi)發(fā)現(xiàn)上層代碼沒(méi)有參數(shù)嗎？
這種代碼實(shí)際就是布置任務(wù)。
跟低層使用什么方式?jīng)]有關(guān)系。

csumck

回復(fù) 4# cobras


    你說(shuō)的那種方式, 查詢完成后一定是通過(guò)回調(diào)函數(shù)去發(fā)送響應(yīng)的. 而這種方式是不需要回調(diào)函數(shù)的, 在代碼上跟阻塞調(diào)用是一樣的, 對(duì)于剛剛接受網(wǎng)絡(luò)編程的新手來(lái)說(shuō), 這種方式使他們完全不需要理解什么同步異步的概念, 因?yàn)榭瓷先ゴ�碼就是順序執(zhí)行的.

shang2010

do_blocked_query()
一個(gè)api+參數(shù)的問(wèn)題，竟然搞出了兩個(gè)函數(shù)出來(lái)了，

關(guān)鍵就是這個(gè)函數(shù)調(diào)用了底層，可惜比不上回調(diào)函數(shù)，也不清楚c++這塊有沒(méi)有什么方案

shang2010

最新的 c sharp都支持異步回調(diào)編碼的

cokeboL

get_request();
do_blocked_query(); / do_noblocked_query();

把這兩句看成一個(gè)原子，或者內(nèi)部加了鎖之類的

井蛙夏蟲(chóng)

boost thread里面的future與這相似(c++11也有)，不過(guò)這個(gè)線程還是處于阻塞狀態(tài)，必須等待異步執(zhí)行完畢才能繼續(xù)執(zhí)行，與阻塞調(diào)用方式比較，沒(méi)有什么優(yōu)勢(shì)。
實(shí)現(xiàn)方式猜測(cè)可能是使用條件變量。

群雄逐鹿中原

有啥牛逼的，C語(yǔ)言實(shí)現(xiàn)，無(wú)非就是多線程或setjump/longjump。。
過(guò)分的追求這種技巧，是代碼水平不高的表現(xiàn)。