boost库的网络编程asio（每隔固定时间干活）

东方耀

    std::cout << "boost库的网络编程asio（每隔固定时间干活）" << endl;
    // 用到的技术点：asio io_service async_wait boost::bind expires_at

1. #include <iostream>
   
2. #include <boost/asio.hpp>
   
3. #include <boost/bind.hpp>
   
4. #include <boost/date_time/posix_time/posix_time.hpp>
   
5. 
   
6. 
   
7. using namespace std;
   
8. 
   
9. void print(const boost::system::error_code&, boost::asio::deadline_timer *t, int *count){
   
10.     if(*count < 5){
    
11.         std::cout << "次数：" << *count << std::endl;
    
12.         ++(*count);
    
13.         t->expires_at(t->expires_at() + boost::posix_time::seconds(1));
    
14.         // 有了lambda函数后不推荐用bind了
    
15.         //"boost" 没有成员 "bind  要引入：#include <boost/bind.hpp>
    
16.         t->async_wait(boost::bind(print, boost::asio::placeholders::error, t, count));
    
17.     }
    
18. 
    
19. }
    
20. 
    
21. 
    
22. void callback(const boost::system::error_code&){
    
23.     std::cout << "1秒后干的事情！" << endl;
    
24. }
    
25. 
    
26. 
    
27. void async_call(){
    
28.     int count=0;
    
29.     boost::asio::io_service io;
    
30.     // 异步调用模式下：可以注册多个事件 循环调用 多次重复
    
31.     // 事件的注册 1
    
32.     boost::asio::deadline_timer t(io, boost::posix_time::seconds(1));
    
33.     // t.async_wait(callback);
    
34.     t.async_wait(boost::bind(print, boost::asio::placeholders::error, &t, &count));
    
35.    
    
36.     std::cout << "直接到这，不阻塞" << endl;
    
37. 
    
38.     io.run();  // 阻塞是在run里的，run()相当于一个while循环 结束条件：1、io.stop() 2、没有事件了
    
39. 
    
40.     std::cout << "最终的结果：" << count << std::endl;
    
41.    
    
42. }
    
43. 
    
44. int main(){
    
45. 
    
46.     //target_link_libraries(main -lboost_system)
    
47.     std::cout << "boost库的网络编程asio（每隔固定时间干活）" << endl;
    
48.     // 用到的技术点：asio io_service async_wait boost::bind expires_at
    
49. 
    
50.     async_call();
    
51. 
    
52.     return 0;
    
53. }

复制代码

不用boost::bind,而用lambda函数在编译的时候会内联展开 效率比function要高

1. #include <iostream>
   
2. #include <boost/asio.hpp>
   
3. #include <boost/date_time/posix_time/posix_time.hpp>
   
4. 
   
5. 
   
6. using namespace std;
   
7. 
   
8. void print(const boost::system::error_code&, boost::asio::deadline_timer& t, int& count){
   
9.     if(count < 5){
   
10.         std::cout << "次数：" << count << std::endl;
    
11.         ++count;
    
12.         t.expires_at(t.expires_at() + boost::posix_time::seconds(1));
    
13.         // 有了lambda函数后不推荐用bind了
    
14.         t.async_wait([&t, &count](const auto& error){
    
15.             print(error, t, count);
    
16.         });
    
17.     }
    
18. 
    
19. }
    
20. 
    
21. 
    
22. void callback(const boost::system::error_code&){
    
23.     std::cout << "1秒后干的事情！" << endl;
    
24. }
    
25. 
    
26. 
    
27. void async_call(){
    
28.     int count=0;
    
29.     boost::asio::io_service io;
    
30.     // 异步调用模式下：可以注册多个事件 循环调用 多次重复
    
31.     // 事件的注册 1
    
32.     boost::asio::deadline_timer t(io, boost::posix_time::seconds(1));
    
33.     // t.async_wait(callback);
    
34.     // t.async_wait(boost::bind(print, boost::asio::placeholders::error, &t, &count));
    
35.     // 不用boost::bind,而用lambda函数在编译的时候会内联展开 效率比function要高
    
36.     t.async_wait([&t, &count](const auto& error){
    
37.         print(error, t, count);
    
38.     });
    
39.    
    
40.     std::cout << "直接到这，不阻塞" << endl;
    
41. 
    
42.     io.run();  // 阻塞是在run里的，run()相当于一个while循环 结束条件：1、io.stop() 2、没有事件了
    
43. 
    
44.     std::cout << "最终的结果：" << count << std::endl;
    
45.    
    
46. }
    
47. 
    
48. int main(){
    
49. 
    
50.     //target_link_libraries(main -lboost_system)
    
51.     std::cout << "boost库的网络编程asio（每隔固定时间干活）不用boost::bind" << endl;
    
52.     // 用到的技术点：asio io_service async_wait boost::bind expires_at
    
53. 
    
54.     async_call();
    
55. 
    
56.     return 0;
    
57. }

复制代码