Boost.Asio C++ 網(wǎng)絡(luò)編程:deadline_timer使用說明
? ? ? ?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)在這個io_service上的deadline_timer。
一.構(gòu)造函數(shù)
在構(gòu)造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);
注意后兩種的區(qū)別。以下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只維護(hù)一個超時時間,一個deadline_timer不同時維持多個定時器。
void?wait();?? void?wait(boost::system::error_code&?ec);
這是個同步等待函數(shù),例如:
boost::asio::io_service?io;?? boost::asio::deadline_timer?t(io,?boost::posix_time::seconds(5));?? t.wait();
由于不涉及到異步,該函數(shù)和io_service沒什么關(guān)系。這個函數(shù)在windows下的實現(xiàn)就只是簡單的sleep。因此也就不存在cancel之說。
三.異步
templateBOOST_ASIO_INITFN_RESULT_TYPE(WaitHandler, ?????void?(boost::system::error_code)) ?async_wait(BOOST_ASIO_MOVE_ARG(WaitHandler)?handler)
注意這個error很重要,表明這個handler是因為超時被執(zhí)行還是因為被cancel。
符合2種情況之一,handler被執(zhí)行:超時或者被cancel。
這同時隱含的說明了除非io.stop被調(diào)用,否則handler一定會被執(zhí)行。即便是被cancel。
被cancel有多種方法,直接調(diào)用cancel或者調(diào)用expires_at,expires_from_now重新設(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!





