boost库asio详解4——deadline_timer使用说明

deadline_timer和socket一样,都用io_service作为构造函数的参数。也即,在其上进行异步操作,都将导致和io_service所包含的iocp相关联。这同样意味着在析构 io_service之前,必须析构关联在这个io_service上的deadline_timer。
1. 构造函数 在构造deadline_timer时指定时间。
[cpp] view plain copy print ?

  1. basic_deadline_timer(
  2. boost::asio::io_service & io_service);
  3. basic_deadline_timer(
  4. boost::asio::io_service & io_service,
  5. const time_type & expiry_time);
  6. basic_deadline_timer(
  7. boost::asio::io_service & io_service,
  8. const duration_type & expiry_time);
注意后两种的区别。以下2种用法是等价的:
[cpp] view plain copy print ?
  1. boost::asio::deadline_timer t(io, boost::posix_time::microsec_clock::universal_time()+boost::posix_time::seconds(5));
  2. boost::asio::deadline_timer t(io, boost::posix_time::seconds(5));
前者是绝对时间,后者是相对时间。
2. 同步 一个deadline_timer只维护一个超时时间,一个deadline_timer不同时维持多个定时器。
[cpp] view plain copy print ?
  1. void wait();
  2. void wait(boost::system::error_code& ec);
这是个同步等待函数,例如:
[cpp] view plain copy print ?
  1. boost::asio::io_service io;
  2. boost::asio::deadline_timer t(io, boost::posix_time::seconds(5));
  3. t.wait();
由于不涉及到异步,该函数和io_service没什么关系。这个函数在windows下的实现就只是简单的sleep。因此也就不存在cancel之说。
3. 异步 [cpp] view plain copy print ?
  1. template
  2. void async_wait(WaitHandler handler);
注意这个error很重要,表明这个handler是因为超时被执行还是因为被cancel。
符合2种情况之一,handler被执行:超时或者被cancel。
这同时隐含的说明了除非io.stop被调用,否则handler一定会被执行。即便是被cancel。
被cancel有多种方法,直接调用cancel或者调用expires_at,expires_from_now重新设置超时时间。
4. 例子 [cpp] view plain copy print ?
  1. namespace
  2. {
  3. void print(const boost::system::error_code&)
  4. {
  5. PRINT_DEBUG("Hello, world!");
  6. }
  7. void handle_wait(const boost::system::error_code& error,
  8. boost::asio::deadline_timer& t,
  9. int& count)
  10. {
  11. if(!error)
  12. {
  13. PRINT_DEBUG(count);
  14. if(count++ < 5)
  15. {
  16. t.expires_from_now(boost::posix_time::seconds(3));
  17. t.async_wait(boost::bind(handle_wait,
  18. boost::asio::placeholders::error,
  19. boost::ref(t),
  20. boost::ref(count)));
  21. if (count == 3)
  22. {
  23. t.cancel();
  24. }
  25. }
  26. }
  27. }
  28. }
  29. // 同步方法
  30. void test_timer_syn()
  31. {
  32. boost::asio::io_service ios;
  33. boost::asio::deadline_timer t(ios, boost::posix_time::seconds(3));
  34. PRINT_DEBUG(t.expires_at());
  35. t.wait();
  36. PRINT_DEBUG("Hello syn deadline_timer!");
  37. }
  38. // 异步方法: 3秒后执行print方法.
  39. void test_timer_asyn()
  40. {
  41. boost::asio::io_service io;
  42. boost::asio::deadline_timer t(io, boost::posix_time::seconds(3));
  43. t.async_wait(print);
  44. PRINT_DEBUG("After async_wait...");
  45. io.run();
  46. }
  47. // 异步循环执行方法:
  48. void test_timer_asyn_loop()
  49. {
  50. boost::asio::io_service io;
  51. boost::asio::deadline_timer t(io);
  52. size_t a = t.expires_from_now(boost::posix_time::seconds(1));
  53. int count = 0;
  54. t.async_wait(boost::bind(handle_wait,
  55. boost::asio::placeholders::error,
  56. boost::ref(t),
  57. boost::ref(count)));
  58. io.run();
  59. }

    推荐阅读