青青草原综合久久大伊人导航_色综合久久天天综合_日日噜噜夜夜狠狠久久丁香五月_热久久这里只有精品

colorful

zc qq:1337220912

 

boost::asio::deadline_timer

注意deadline_timer和socket一樣,都用 io_service作為構造函數的參數。也即,在其上進行異步操作,都將導致和io_service所包含的iocp相關聯。這同樣意味著在析構 io_service之前,必須析構關聯在這個io_service上的deadline_timer。

一個deadline_timer只維護一個超時時間,一個deadline_timer不同時維持多個定時器。

void wait();
void
wait(boost::system::error_code & ec);

這是個同步等待函數,例如:

boost::asio::io_service io;
boost::asio::deadline_timer t(io, boost::posix_time::seconds(5));
t.wait();
由于不涉及到異步,該函數和io_service沒什么關系。這個函數在windows下的實現就只是簡單的Sleep。因此也就不存在cancel之說。

如果t的expire時間已過,那么t.wait會立刻返回。

例如如下代碼:

boost::asio::io_service io; 
boost::asio::deadline_timer t(io, boost::posix_time::seconds(5));
t.wait();
t.wait();

第一個t.wait會等待5s才返回,第2個t.wait會立刻返回。

wait函數本身沒有參數,不存在t.wait(seconds(5))的用法。

可以在構造deadline_timer時指定時間。

basic_deadline_timer(
boost::asio::io_service & io_service);

basic_deadline_timer(
boost::asio::io_service & io_service,
const time_type & expiry_time);

basic_deadline_timer(
boost::asio::io_service & io_service,
const duration_type & expiry_time);

注意后兩種的區別。以下2種用法是等價的:

boost::asio::deadline_timer t(io, boost::posix_time::microsec_clock::universal_time()+boost::posix_time::seconds(5));

boost::asio::deadline_timer t(io, boost::posix_time::seconds(5));

前者是絕對時間,后者是相對時間。

除了在deadline_timer構造函數中指定時間,也可以使用如下2個函數指定時間:

expires_at,expires_from_now。這兩個函數的區別是前者參數是絕對時間,后者是相對時間。例如:

boost::asio::io_service io;

boost::asio::deadline_timer t(io);

t.expires_from_now(boost::posix_time::seconds(5));

t.wait();

注意這兩個函數除了設定下次超時時間之外,還有一個效果是取消前面所有的異步wait。詳情參看關于這兩個函數的詳細解釋。

template<
    typename
WaitHandler>
void async_wait(
    WaitHandler handler);
其中void handler(
const boost::system::error_code& error // Result of operation.
);

注意這個error很重要,表明這個handler是因為超時被執行還是因為被cancel。
符合2種情況之一,handler被執行:超時或者被cancel。
這同時隱含的說明了除非io.stop被調用,否則handler一定會被執行。即便是被cancel。
被cancel有多種方法,直接調用cancel或者調用expires_at,expires_from_now重新設置超時時間。
void handle_wait(const boost::system::error_code& error,
boost::asio::deadline_timer& t,int& count)
{
if(!error)
{
std::cout<< count<<"\n";
if(count++<5)
{
t.expires_from_now(boost::posix_time::seconds(1));
t.async_wait(boost::bind(handle_wait,boost::asio::placeholders::error,
boost::ref(t),boost::ref(count)));
}
}
}

int main()
{
boost::asio::io_service io;
boost::asio::deadline_timer t(io);
size_t a = t.expires_from_now(boost::posix_time::seconds(1));
int count = 0;
t.async_wait(boost::bind(handle_wait,boost::asio::placeholders::error,
boost::ref(t),boost::ref(count)));
io.run();
return 0;
}

deadline_timer的析構函數什么也不做,因此不會導致發出的async_wait被cancel。

std::size_t cancel();

std::size_t
cancel(
    boost::system::error_code & ec);
此函數調用會導致所有尚未返回的async_wait(handler)的handler被調用,同時error_code為boost::asio::error::operation_aborted。返回值是被cancel的timer數量。

 time_type expires_at() const;

std::size_t
expires_at(
const time_type & expiry_time);

std::size_t
expires_at(
const time_type & expiry_time,
boost::system::error_code & ec);
duration_type expires_from_now() const;

std::size_t
expires_from_now(
const duration_type & expiry_time);

std::size_t
expires_from_now(
const duration_type & expiry_time,
boost::system::error_code & ec);
以上2組函數用來設置新的超時時間,同時cancel所有未完成的async_wait操作。注意這兩個函數的返回值即為cancel的操作數量。
考慮如下場景,我們有一個workerthread正在調用io_work.run();

此時主線程向workerthread發出了一個異步調用,例如post(...),考慮到io_work.run很可能積壓了很多handlers沒有處理,或者某些handlers處理非常耗時,希望它在5s內必須返回。那么可以:

void handle_wait(const boost::system::error_code& error,bool& Ret)
{
    if(!error) Ret = false;
}

void handle_func(
    boost::shared_ptr<boost::asio::deadline_timer> t,
    boost::shared_ptr<boost::asio::io_service> io,
    int* v)
{
    boost::asio::io_service::work work(*io);

    if(t->cancel()>0)
    {       
        *v = 1;
    }
}

void func_delay_1_second()
{
    boost::asio::io_service io;
    boost::asio::deadline_timer t(io,boost::posix_time::seconds(1));
    t.wait();
}

bool sync_func(int& v,boost::asio::io_service& io_work)
{
    boost::shared_ptr<boost::asio::io_service> io(new boost::asio::io_service);
    boost::shared_ptr<boost::asio::deadline_timer> t(new boost::asio::deadline_timer(*io));
    t->expires_from_now(boost::posix_time::seconds(5));
    bool ret = true;
    t->async_wait(boost::bind(handle_wait,boost::asio::placeholders::error,boost::ref(ret)));
    io_work.post(boost::bind(handle_func,t,io,&v));
    io->run();
    return ret;
}

int main()
{
    boost::asio::io_service io_work;
    auto_ptr<boost::asio::io_service::work> work(new boost::asio::io_service::work(io_work));
    boost::thread workthread(boost::bind(&boost::asio::io_service::run, &io_work));
    for(int i=0;i<3;++i) io_work.post(func_delay_1_second);

    int v = 0;
    bool ret = sync_func(v,io_work);
    if(ret) printf("v %d\n",v);

    work.reset();
    workthread.join();
    return 0;
}

上面代碼中如果先進入handle_wait,則表明超時,此時設置ret = false,然后io.run會退出,表明調用失敗,如果稍后進入handle_func,則t->cancel會返回0,也不做任何操作。雖然在 io.run退出時會釋放v,但由于handle_func不做任何操作因此也不會引起任何安全問題。如果handle_func先進入,則首先使用 work讓io.run不會退出,然后取消timer,并且設置,隨后work析構,io.run會退出。注意這里面的同步問題:如果先進入 handle_wait,隨后進入handle_func,那么handle_func中的t->cancel會返回0從而不做任何事。如果先進入 handle_func,隨后進入handle_wait,那么t->cancel或者返回0或者返回1,由于使用了work,io.run也不會 退出。注意這里的t和io都是shared_ptr的,否則因為如果handle_wait先返回,則io.run會立刻退出并析 構,handle_func中將使用懸空的t和io,將導致非法操作。注意這里的io必須是shared_ptr的,如果 boost::asio::io_service::work work(*io); 改成work(t->get_ioservice());則t是有效的,而t所索引的io_service已經無效了,同樣會導致非法操作。牢記 io_service的使用原則:必須首先析構所有索引的其他對象之后才能析構io_service。

posted on 2012-03-30 16:39 多彩人生 閱讀(2285) 評論(1)  編輯 收藏 引用

評論

# re: boost::asio::deadline_timer[未登錄] 2012-11-27 17:22 lin

請教下
有沒有支持多個定時器的timer呢?  回復  更多評論   


只有注冊用戶登錄后才能發表評論。
網站導航: 博客園   IT新聞   BlogJava   博問   Chat2DB   管理


導航

統計

常用鏈接

留言簿(3)

隨筆分類

隨筆檔案

搜索

最新評論

閱讀排行榜

評論排行榜

青青草原综合久久大伊人导航_色综合久久天天综合_日日噜噜夜夜狠狠久久丁香五月_热久久这里只有精品
  • <ins id="pjuwb"></ins>
    <blockquote id="pjuwb"><pre id="pjuwb"></pre></blockquote>
    <noscript id="pjuwb"></noscript>
          <sup id="pjuwb"><pre id="pjuwb"></pre></sup>
            <dd id="pjuwb"></dd>
            <abbr id="pjuwb"></abbr>
            1024日韩| 国产免费观看久久黄| 日韩午夜黄色| 夜夜嗨av一区二区三区| 国产精品99久久久久久白浆小说| 欧美日韩视频在线一区二区 | 亚洲精品一品区二品区三品区| 欧美区日韩区| 性视频1819p久久| 亚洲黄色三级| 欧美日韩国产综合新一区| 久久不射2019中文字幕| 99国产精品99久久久久久| 亚洲免费观看高清完整版在线观看熊| 午夜精品久久| 在线视频日本亚洲性| 在线成人激情黄色| 国产精品av久久久久久麻豆网| 久久五月激情| 午夜国产精品视频| 中文网丁香综合网| 最新日韩在线| 亚洲午夜在线观看| 一卡二卡3卡四卡高清精品视频| 欧美激情国产精品| 美女主播一区| 牛牛国产精品| 久久综合伊人77777尤物| 亚洲欧美日韩国产一区| 亚洲伦伦在线| 亚洲日本一区二区三区| 亚洲欧美区自拍先锋| 嫩草成人www欧美| 亚洲视频一区二区| 猫咪成人在线观看| 欧美国产欧美综合| 欧美精品久久久久久久| 欧美国产日韩一区二区三区| 国产精品红桃| 国产精品va在线| 在线国产精品播放| 久久国内精品自在自线400部| 欧美一区激情| 久久久噜噜噜久久中文字幕色伊伊| 亚洲一区二区三区国产| 亚洲视频在线观看| 美日韩精品视频免费看| 亚洲欧美另类久久久精品2019| 亚洲欧美国产va在线影院| 欧美大片免费看| 欧美视频日韩视频| 国产区精品在线观看| 久久精品成人一区二区三区蜜臀| 久久综合给合久久狠狠狠97色69| 麻豆成人在线| 国产午夜精品美女视频明星a级| 国产午夜精品福利| 午夜在线成人av| 免费观看成人| 久久久美女艺术照精彩视频福利播放| 久久理论片午夜琪琪电影网| 国产欧美一区二区精品婷婷| 在线视频欧美日韩精品| 亚洲精品美女久久久久| 亚洲欧美日产图| 国产精品日韩一区二区| 精品88久久久久88久久久| 亚洲日本成人| 日韩网站免费观看| 欧美激情精品久久久久久变态| 久久精品一区二区三区中文字幕| 美腿丝袜亚洲色图| 亚洲国产成人av| 亚洲性线免费观看视频成熟| 亚洲激情视频| 欧美日韩99| 一区二区三区日韩精品视频| 夜夜嗨av色综合久久久综合网 | 欧美在线资源| 欧美另类变人与禽xxxxx| 日韩视频中午一区| 宅男精品导航| 国产在线观看91精品一区| 一本久久综合亚洲鲁鲁五月天| 久久精品亚洲| 美女日韩在线中文字幕| 99这里只有久久精品视频| 宅男噜噜噜66一区二区66| 国产欧美日韩综合一区在线播放| 久久久噜噜噜久久狠狠50岁| 嫩草伊人久久精品少妇av杨幂| 狠狠狠色丁香婷婷综合激情| 亚洲神马久久| 亚洲欧美一区二区三区久久| 欲色影视综合吧| 亚洲最新在线视频| 狠狠色综合色综合网络| 亚洲精品乱码久久久久久蜜桃麻豆| 国产精品久久一卡二卡| 亚洲素人一区二区| 欧美在线一二三四区| 亚洲欧洲在线一区| 亚洲欧美日韩直播| 日韩手机在线导航| 久久精品99| 亚洲欧美国产不卡| 欧美成人有码| 久久久久欧美| 国产精品久久久999| 欧美大片91| 欧美www视频| 国产精品免费aⅴ片在线观看| 在线观看国产成人av片| 99国内精品久久| 有码中文亚洲精品| 亚洲欧美视频在线观看| 一区二区欧美国产| 美女国产一区| 久久亚洲影院| 玖玖国产精品视频| 欧美在线视频播放| 欧美亚洲尤物久久| 精品99一区二区三区| 一区二区三区精品在线| 亚洲激情第一区| 日韩视频在线一区二区三区| 国产一区二区三区在线免费观看| 久久久久一区二区三区| 国产精品爱啪在线线免费观看| 亚洲第一中文字幕在线观看| 欧美日韩精品一区二区三区| 欧美va亚洲va国产综合| 黄色成人精品网站| 欧美一区二区视频在线观看2020| 亚洲欧美影院| 国产精品久久久久久久久免费| 日韩视频永久免费| 亚洲手机成人高清视频| 欧美日韩国产小视频| 亚洲激情二区| 一区二区三区不卡视频在线观看| 欧美大香线蕉线伊人久久国产精品| 亚洲国产精品999| 久久综合久久综合九色| 久久久久久久欧美精品| 欧美顶级艳妇交换群宴| 欧美成人在线影院| 日韩一区二区精品视频| 欧美日韩不卡| 亚洲调教视频在线观看| 午夜日韩在线| 国产一区三区三区| 美女脱光内衣内裤视频久久网站| 亚洲国产黄色| 午夜精品一区二区三区在线视 | 亚洲精品欧美日韩| 国产午夜精品久久久| 久久精品99久久香蕉国产色戒| 久热这里只精品99re8久| 亚洲国产电影| 欧美人牲a欧美精品| 亚洲综合日韩在线| 久久综合给合| 99视频精品免费观看| 欧美亚日韩国产aⅴ精品中极品| 亚洲你懂的在线视频| 免费欧美电影| 亚洲一区二区少妇| 影音先锋一区| 欧美三级乱码| 久久久青草青青国产亚洲免观| 亚洲精品免费在线| 久久久伊人欧美| 夜夜爽www精品| 国产午夜精品理论片a级大结局 | 欧美影院久久久| 激情欧美丁香| 国产精品成人一区| 久久狠狠久久综合桃花| 亚洲激情婷婷| 美女黄网久久| 欧美在线观看一区| 99视频精品在线| 樱花yy私人影院亚洲| 国产精品国产亚洲精品看不卡15| 可以看av的网站久久看| 亚洲综合精品| 日韩天堂在线观看| 欧美jizz19hd性欧美| 性欧美办公室18xxxxhd| 亚洲精品一二| 亚洲国产日韩在线一区模特| 国产乱理伦片在线观看夜一区 | 欧美日韩国产丝袜另类| 久久亚洲综合色一区二区三区| 亚洲一区二区三区免费观看| 亚洲欧美国内爽妇网| 91久久极品少妇xxxxⅹ软件| 国产乱码精品一区二区三区忘忧草 | 久久精品人人做人人爽电影蜜月|