1. //boost::posix_time::to_simple_string函数需要这两个头文件  
    2. #include <boost/date_time.hpp>  
    3. #include <boost/date_time/posix_time/ptime.hpp>  
    4. //使用boost.chrono代替std.chrono,  
    5. #define BOOST_ASIO_DISABLE_STD_CHRONO  
    6. #include <boost/asio.hpp>  
    7. #include <boost/asio/steady_timer.hpp>  
    8. #include <boost/asio/placeholders.hpp>  
    9. #include <boost/thread.hpp>  
    11. class MyClass  
    12. {  
    13. public:  
    14.     MyClass() :m_work(m_io), m_timer(m_io){}  
    15. public:  
    16.     boost::thread_group m_thgp;  
    17.     boost::asio::io_service m_io;  
    18.     boost::asio::io_service::work m_work;  
    19.     boost::asio::steady_timer m_timer;  
    20. public:  
    21.     void Init()  
    22.     {  
    23.         boost::system::error_code errCode;  
    24.         m_thgp.create_thread(boost::bind(&boost::asio::io_service::run, boost::ref(m_io), errCode));  
    25.         std::cout << "Init_1, " << LocalTime() << std::endl;  
    26.         m_timer.expires_from_now(boost::chrono::milliseconds(4000)); //设置过期时间长度  
    27. #if 0  
    28.         m_timer.expires_from_now(std::chrono::milliseconds(4000));  
    29. #endif  
    30.         std::cout << "Init_2, " << LocalTime() << std::endl;  
    31.         m_timer.async_wait(boost::bind(&MyClass::Test, this, boost::asio::placeholders::error));//异步等待  
    32.         std::cout << "Init_3, " << LocalTime() << std::endl;  
    33.         //由Console可知, 函数立即返回了, 定时器的expires_from_now是由完成端口处理的  
    34.     }  
    35.     void Stop()  
    36.     {  
    37.         std::cout << "Stop_1, " << LocalTime() << std::endl;  
    38.         m_timer.cancel();  // 取消所有handler  
    39.         m_work.~work();  
    40.         m_thgp.join_all();  
    41.         std::cout << "Stop_2, " << LocalTime() << std::endl;  
    42.     }  
    43.     static std::string LocalTime()  
    44.     {  
    45.         return boost::posix_time::to_simple_string(boost::posix_time::microsec_clock::local_time());  
    46.     }  
    48.     void Test(const boost::system::error_code& ec)  
    49.     {  
    50.         printf("test_1, %s, ec.value=%d, ec.message=%s\n", LocalTime().c_str(), ec.value(), ec.message().c_str());  
    51.         if (ec)  return;  
    52.         m_timer.expires_from_now(boost::chrono::milliseconds(4000));  
    53. #if 0  
    54.         m_timer.expires_from_now(std::chrono::milliseconds(4000));  
    55. #endif  
    56.         std::cout << "test_2, " << LocalTime() << std::endl;  
    57.         m_timer.async_wait(boost::bind(&MyClass::Test, boost::ref(*this), _1));  
    58. #if 0  
    59.         m_timer.async_wait(boost::bind(&MyClass::Test, this, _1));  
    60.         m_timer.async_wait(boost::bind(&MyClass::Test, this, boost::asio::placeholders::error));  
    61. #endif  
    62.         std::cout << "test_3, " << LocalTime() << std::endl;  
    63.     }  
    64. };  
    66. int main(int argc, char** argv)  
    67. {  
    68.     MyClass my;  
    69.     my.Init();  
    70.     for (int i = 0; i < 30; ++i)  
    71.     {  
    72.         boost::this_thread::sleep_for(boost::chrono::milliseconds(1000));  
    73.     }  
    74.     my.Stop();  
    75.     std::cout << "press ENTER to exit..." << std::endl;  
    76.     std::cin.sync();  
    77.     while (getchar() != '\n') {}  
    78. }