Boost.Asio C++ 網(wǎng)絡(luò)編程:deadline_timer使用說(shuō)明
? ? ? ?deadline_timer和socket一樣,都用io_service作為構(gòu)造函數(shù)的參數(shù)。也即,在其上進(jìn)行異步操作,都將導(dǎo)致和io_service所包含的iocp相關(guān)聯(lián)。這同樣意味著在析構(gòu) io_service之前,必須析構(gòu)關(guān)聯(lián)在這個(gè)io_service上的deadline_timer。
一.構(gòu)造函數(shù)
在構(gòu)造deadline_timer時(shí)指定時(shí)間。
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);
注意后兩種的區(qū)別。以下2種用法是等價(jià)的:
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));
前者是絕對(duì)時(shí)間,后者是相對(duì)時(shí)間。
二.同步
一個(gè)deadline_timer只維護(hù)一個(gè)超時(shí)時(shí)間,一個(gè)deadline_timer不同時(shí)維持多個(gè)定時(shí)器。
void?wait();?? void?wait(boost::system::error_code&?ec);
這是個(gè)同步等待函數(shù),例如:
boost::asio::io_service?io;?? boost::asio::deadline_timer?t(io,?boost::posix_time::seconds(5));?? t.wait();
由于不涉及到異步,該函數(shù)和io_service沒(méi)什么關(guān)系。這個(gè)函數(shù)在windows下的實(shí)現(xiàn)就只是簡(jiǎn)單的sleep。因此也就不存在cancel之說(shuō)。
三.異步
templateBOOST_ASIO_INITFN_RESULT_TYPE(WaitHandler, ?????void?(boost::system::error_code)) ?async_wait(BOOST_ASIO_MOVE_ARG(WaitHandler)?handler)
注意這個(gè)error很重要,表明這個(gè)handler是因?yàn)槌瑫r(shí)被執(zhí)行還是因?yàn)楸籧ancel。
符合2種情況之一,handler被執(zhí)行:超時(shí)或者被cancel。
這同時(shí)隱含的說(shuō)明了除非io.stop被調(diào)用,否則handler一定會(huì)被執(zhí)行。即便是被cancel。
被cancel有多種方法,直接調(diào)用cancel或者調(diào)用expires_at,expires_from_now重新設(shè)置超時(shí)時(shí)間。
四.例子
#ifdef?WIN32 #define?_WIN32_WINNT?0x0501 #include#endif #include#include#include#include#includeusing?namespace?boost::asio; void?print(const?boost::system::error_code&) { std::cout?<<?"Hello,?world!"?<<?std::endl; } void?handle_wait(const?boost::system::error_code&?error, boost::asio::deadline_timer&?t, int&?count) { if?(!error) { std::cout?<<?count?<<?std::endl; if?(count++?<?5) { t.expires_from_now(boost::posix_time::seconds(3)); t.async_wait(boost::bind(handle_wait, boost::asio::placeholders::error, boost::ref(t), boost::ref(count))); if?(count?==?3) { t.cancel(); } } } } //?同步方法?? void?test_timer_syn() { boost::asio::io_service?ios; boost::asio::deadline_timer?t(ios,?boost::posix_time::seconds(3)); t.wait(); std::cout?<<?"syn?deadline_timer!"?<<?std::endl; } //?異步方法:3秒后執(zhí)行print方法 void?test_timer_asyn() { boost::asio::io_service?io; boost::asio::deadline_timer?t(io,?boost::posix_time::seconds(3)); t.async_wait(print); std::cout?<<?"asyn?deadline_timer!"?<<?std::endl; io.run(); } //?異步循環(huán)執(zhí)行方法 void?test_timer_asyn_loop() { 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?=?1; t.async_wait(boost::bind(handle_wait, boost::asio::placeholders::error, boost::ref(t), boost::ref(count))); io.run(); } int?main(int?argc,?char*?argv[])?{ // test_timer_syn(); test_timer_asyn(); // test_timer_asyn_loop(); system("pause"); }
異步方法執(zhí)行的結(jié)果如下所示:
先打印出asyn deadline_timer!,三秒后打印Hello,world!