請教一下關(guān)于異步函數(shù)接口得實(shí)現(xiàn)

bittertea

原來項(xiàng)目里得SOCKET客戶端得都是同步形式得接口, 調(diào)用會阻塞在C-S交互數(shù)據(jù)包上,
現(xiàn)在打算把接口改為異步得, 接口打算如下形式

//初始化異步庫, user_cb在接口調(diào)用完成時回調(diào)
async_handle async_init(user_cb, void *argv);

//一些異步接口, 基本操作是與服務(wù)器交互數(shù)據(jù)
async_proc1(async_handle, param1, param2, ...);
async_proc2(async_handle, param1, param2, ...);.....

//反初始化異步庫
async_uninit(async_handle);

現(xiàn)在打算采用基于libevent庫實(shí)現(xiàn)

一. async_init得操作邏輯:
1.做event_base(事件調(diào)度器)初始化, 然后創(chuàng)建兩個管道:pipe1, pipe2.
pipe1用于做執(zhí)行async_proc1()內(nèi)部得具體操作通知,
pipe2用于做async_proc1()內(nèi)部具體操作執(zhí)行完畢后得通知.
pipe2得讀事件具體回調(diào)event_pipe2_cb為讀取async_proc1()得執(zhí)行結(jié)果ret.
向event_base注冊pipe2[1]得讀事件.

2. 新創(chuàng)建事件監(jiān)測線程dispatch_thd, 該線程內(nèi)部調(diào)用event_loop循環(huán)檢測pipe1, pipe2注冊事件是否被激活,
若激活則執(zhí)行具體注冊得回調(diào)操作

二. async_proc1得操作邏輯
1. 先將與服務(wù)器得耗時得交互 封裝好子函數(shù)send_recv_data, 并且返回值存到ret變量中,
封裝pipe1得讀事件回調(diào)函數(shù)event_pipe1_cb, 該回調(diào)內(nèi)部先ret = send_recv_data, 執(zhí)行user_cb,
最后再write(pipe2[0], "")寫具體執(zhí)行結(jié)果通知, 從而激活pipe2[1]得讀事件回調(diào)event_pipe2_cb

2.  注冊pipe1[1]得讀事件回調(diào)函數(shù)event_pipe1_callback, 然后write(pipe1[0], "") //寫執(zhí)行具體操作通知,
從而激活pipe1[1]得讀事件回調(diào)event_pipe1_callback

3. async_proc1返回是否注冊事件成功

三. async_uninit得操作邏輯
通知事件監(jiān)測線程dispatch_thd退出, 反初始化event_base

缺點(diǎn):
由于各異步函數(shù)async_proc1, async_proc2操作均使用pipe1, pipe2管道, 因此若前一個異步調(diào)用未完成實(shí)際得處理,
則應(yīng)不允許進(jìn)行其他異步操作

另外稍微簡單的方式:
采用新建一個隊(duì)列, 和新建線程worker_thd方式, 異步操作直接將操作投遞到隊(duì)列中, worker_thd線程取隊(duì)列并執(zhí)行
操作的方式

請教上述的實(shí)現(xiàn)有什么問題

[ 本帖最后由 bittertea 于 2009-7-22 12:22 編輯 ]

vbs100

如果你單單是因?yàn)?調(diào)用會阻塞在C-S交互數(shù)據(jù)包上 你為什么不做成事件驅(qū)動 用非阻塞方式以網(wǎng)絡(luò)fd可讀做為通知事件的呢

異步方式的實(shí)現(xiàn)效率都不是很高，libc的異步接口也只是為了和標(biāo)準(zhǔn)兼容，libevent怎么實(shí)現(xiàn)不是很清楚，可能用的是線程

你現(xiàn)在還想在libevent的基礎(chǔ)上封裝，等于在操作系統(tǒng)和你的程序之間多了好幾層，我覺得這種方式還不如一個線程多路復(fù)用或一個線程一個client