boost库学习随记六：使用同步定时器、异步定时器、bind、成员函数回调处理、多线程的同步处理示例等

一、使用同步定时器

这个示例程序通过展示如何在一个定时器执行一个阻塞等待。

1. //makefile
2. #----------------------------------------------------------
3. #makefile helloworld测试用例
4. #
5. #
6. #
7. #
8. #-----------------------------------------------------------
9. ggg=g++
10. exe=asiotimer
11. #所有的.o文件写在这里
12. obj = asiotimer.o
13. #所要关联的cpp文件写在这里
14. cpp = asiotimer.cpp
15. #加入库文件
16. libso = -lboost_thread -lboost_system
17. $(exe):$(obj)
18. @echo "链接开始................"
19. $(ggg) $(libso) -o $(exe) $(obj)
20. hw.o : $(cpp)
21. @echo "编译开始................"
22. $(ggg) -std=c++11 -c $(cpp)
23. .PHONY : clean cleanall
24. cleanall:
25. @echo "开始make all..........."
26. -rm -rf $(exe) $(obj)
27. clean:
28. @echo "开始清理................"
29. -rm -rf $(obj)

2、asiotimer.h头文件

1. //asiotimer.h
2. #ifndef __ASIOTIMER__H__
3. #define __ASIOTIMER__H__
4. #include <iostream>
5. #include <boost/asio.hpp>
6. //#define BOOST_DATE_TIME_SOURCE
7. #include "boost/date_time/posix_time/posix_time.hpp"
8. #endif

3、asiotimer.cpp文件

1. //asiotimer.cpp
2. #include "asiotimer.h"
3. int main()
4. {
5. boost::asio::io_service io;
6. boost::asio::deadline_timer t(io,boost::posix_time::seconds(5));
7. t.wait();
8. std::cout<<"hello,world\n";
9. return 0;
10. }

二、使用异步定时器示例

本示例程序演示了如何使用Asio的异步回调功能由示例一修改程序 ，开启计时器执行一个异步等待。

1、makefile文件

makefile 与示例一基本相同，只需要修改
exe=asiotest2

#所有的.o文件写在这里
obj = asiotest2.o

#所要关联的cpp文件写在这里
cpp = asiotest2.cpp

2、asiotest2.h

1. #ifndef __ASIOTEST2__H__
2. #define __ASIOTEST2__H__
3. #include <iostream>
4. #include <boost/asio.hpp>
5. #include <boost/date_time/posix_time/posix_time.hpp>
6. void print(const boost::system::error_code& );
7. #endif

3、asiotest2.cpp

1. #include "asiotest2.h"
2. using namespace std;
3. using namespace boost;
4. void print(const boost::system::error_code& )
5. {
6. std::cout<<"hello,world!\n";
7. }
8. int main()
9. {
10. boost::asio::io_service io;
11. boost::asio::deadline_timer t(io,boost::posix_time::seconds(5));
12. t.async_wait(&print);
13. io.run();
14. return 0;
15. }

三、绑定参数到处理程序

在本示例中，我们将在示例二修改程序，使定时器每秒被激活一次。这将显示如何传递额外的参数给你的处理函数。

1、makefile 文件同示例二makefile修改方法

2、头文件

1. #ifndef __ASIOTEST3__H__
2. #define __ASIOTEST3__H__
3. #include <iostream>
4. #include <boost/asio.hpp>
5. #include <boost/bind.hpp>
6. #include <boost/date_time/posix_time/posix_time.hpp>
7. #endif

3、CPP文件

1. #include "asiotest3.h"
2. void print(const boost::system::error_code&,
3. boost::asio::deadline_timer* t,int* count)
4. {
5. if(*count<5)
6. {
7. std::cout<<*count<<"\n";
8. ++(*count);
9. t->expires_at(t->expires_at() + boost::posix_time::seconds(1));
10. t->async_wait(boost::bind(print,
11. boost::asio::placeholders::error,t,count));
12. }
13. }
14. int main()
15. {
16. boost::asio::io_service io;
17. int count=0;
18. boost::asio::deadline_timer t(io,boost::posix_time::seconds(1));
19. t.async_wait(boost::bind(print,boost::asio::placeholders::error,
20. &t,&count));
21. io.run();
22. std::cout<<"Final count is" <<count<<"\n";
23. return 0;
24. }

四、使用成员函数做为处理程序示例

在本示例中，我们将看到如何使用一个类的成员函数作为回调处理程序。

1、makefile 同上面示例

2、头文件

1. #ifndef __ASIOTEST4__H__
2. #define __ASIOTEST4__H__
3. #include <iostream>
4. #include <boost/asio.hpp>
5. #include <boost/bind.hpp>
6. #include <boost/date_time/posix_time/posix_time.hpp>
7. class printer
8. {
9. public:
10. printer(boost::asio::io_service& io)
11. :timer_(io,boost::posix_time::seconds(1)),
12. count_(0)
13. {
14. timer_.async_wait(boost::bind(&printer::print,this));
15. }
16. ~printer()
17. {
18. std::cout<<"Final count is "<<count_<<"\n";
19. }
20. void print()
21. {
22. if(count_<5)
23. {
24. std::cout<<count_<<std::endl;
25. ++count_;
26. timer_.expires_at(timer_.expires_at()+boost::posix_time::seconds(1));
27. timer_.async_wait(boost::bind(&printer::print,this));
28. }
29. }
30. private:
31. boost::asio::deadline_timer timer_;
32. int count_;
33. };

3、cpp文件

1. #include "asiotest4.h"
2. int main()
3. {
4. boost::asio::io_service io;
5. printer p(io);
6. io.run();
7. return 0;
8. }

五、多线程的同步处理示例

本示例演示boost::asio::strand 在多线程程序中同步回调处理程

1、makefile同上

2、头文件

1. #ifndef __ASIOTEST5__H__
2. #define __ASIOTEST5__H__
3. #include <iostream>
4. #include <boost/asio.hpp>
5. #include <boost/thread/thread.hpp>
6. #include <boost/bind.hpp>
7. #include <boost/date_time/posix_time/posix_time.hpp>
8. class printer
9. {
10. public:
11. printer(boost::asio::io_service& io):strand_(io),
12. timer1_(io,boost::posix_time::seconds(1)),
13. timer2_(io,boost::posix_time::seconds(1)),count_(0)
14. {
15. timer1_.async_wait(strand_.wrap(boost::bind(&printer::print1,this)));
16. timer2_.async_wait(strand_.wrap(boost::bind(&printer::print2,this)));
17. }
18. ~printer()
19. {
20. std::cout<<"Final count is " <<count_<<std::endl;
21. }
22. void print1()
23. {
24. if(count_ < 10)
25. {
26. std::cout<<"Timer 1: "<<count_<<std::endl;
27. ++count_;
28. timer1_.expires_at(timer1_.expires_at() + boost::posix_time::seconds(1));
29. timer1_.async_wait(strand_.wrap(boost::bind(&printer::print1,this)));
30. }
31. }
32. void print2()
33. {
34. if(count_ < 10)
35. {
36. std::cout<<"Timer 2: " <<count_<<std::endl;
37. ++count_;
38. timer2_.expires_at(timer2_.expires_at() + boost::posix_time::seconds(1));
39. timer2_.async_wait(strand_.wrap(boost::bind(&printer::print2,this)));
40. }
41. }
42. private:
43. boost::asio::strand strand_;
44. boost::asio::deadline_timer timer1_;
45. boost::asio::deadline_timer timer2_;
46. int count_;
47. };
48. #endif

3、CPP文件

1. #include "asiotest5.h"
2. int main()
3. {
4. boost::asio::io_service io;
5. printer p(io);
6. boost::thread t(boost::bind(&boost::asio::io_service::run,&io));
7. io.run();
8. t.join();
9. return 0;
10. }

from:

http://blog.****.net/leitianjun/article/details/25740633