boost庫asio詳解4——deadline_timer使用說明
阿新 • • 發佈:2019-02-20
deadline_timer和socket一樣,都用io_service作為建構函式的引數。也即,在其上進行非同步操作,都將導致和io_service所包含的iocp相關聯。這同樣意味著在析構 io_service之前,必須析構關聯在這個io_service上的deadline_timer。
[cpp]view plaincopyprint?
[cpp]view plaincopyprint?
[cpp]view plaincopyprint?
[cpp]view plaincopyprint?
符合2種情況之一,handler被執行:超時或者被cancel。
這同時隱含的說明了除非io.stop被呼叫,否則handler一定會被執行。即便是被cancel。
被cancel有多種方法,直接呼叫cancel或者呼叫expires_at,expires_from_now重新設定超時時間。
1. 建構函式
在構造deadline_timer時指定時間。[cpp]view plaincopyprint?
- 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);
[cpp]view plaincopyprint?
-
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));
2. 同步
一個deadline_timer只維護一個超時時間,一個deadline_timer不同時維持多個定時器。[cpp]view plaincopyprint?
- void wait();
- void wait(boost::system::error_code& ec);
[cpp]view plaincopyprint?
-
boost::asio::io_service io;
- boost::asio::deadline_timer t(io, boost::posix_time::seconds(5));
- t.wait();
3. 非同步
[cpp]view plaincopyprint?- template<typename WaitHandler>
- void async_wait(WaitHandler handler);
符合2種情況之一,handler被執行:超時或者被cancel。
這同時隱含的說明了除非io.stop被呼叫,否則handler一定會被執行。即便是被cancel。
被cancel有多種方法,直接呼叫cancel或者呼叫expires_at,expires_from_now重新設定超時時間。
4. 例子
[cpp]view plaincopyprint?- namespace
- {
- void print(const boost::system::error_code&)
- {
- PRINT_DEBUG("Hello, world!");
- }
- void handle_wait(const boost::system::error_code& error,
- boost::asio::deadline_timer& t,
- int& count)
- {
- if(!error)
- {
- PRINT_DEBUG(count);
- 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));
- PRINT_DEBUG(t.expires_at());
- t.wait();
- PRINT_DEBUG("Hello syn deadline_timer!");
- }
- // 非同步方法: 3秒後執行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);
- PRINT_DEBUG("After async_wait...");
- io.run();
- }
- // 非同步迴圈執行方法:
- 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 = 0;
- t.async_wait(boost::bind(handle_wait,
- boost::asio::placeholders::error,
- boost::ref(t),
- boost::ref(count)));
- io.run();
- }