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

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

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

2024-07-27 00:10:28 218人阅读

一、使用同步定时器

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

[cpp] view plaincopy

//makefile
#----------------------------------------------------------
#makefile helloworld测试用例
#
#
#
#
#-----------------------------------------------------------
ggg=g++
exe=asiotimer
#所有的.o文件写在这里
obj = asiotimer.o
#所要关联的cpp文件写在这里
cpp = asiotimer.cpp
#加入库文件
libso = -lboost_thread -lboost_system
$(exe):$(obj)
@echo "链接开始................"
$(ggg) $(libso) -o $(exe) $(obj)
hw.o : $(cpp)
@echo "编译开始................"
$(ggg) -std=c++11 -c $(cpp)
.PHONY : clean cleanall
cleanall:
@echo "开始make all..........."
-rm -rf $(exe) $(obj)
clean:
@echo "开始清理................"
-rm -rf $(obj)

2、asiotimer.h头文件

[cpp] view plaincopy

//asiotimer.h
#ifndef __ASIOTIMER__H__
#define __ASIOTIMER__H__
#include <iostream>
#include <boost/asio.hpp>
//#define BOOST_DATE_TIME_SOURCE
#include "boost/date_time/posix_time/posix_time.hpp"
#endif

3、asiotimer.cpp文件

[cpp] view plaincopy

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

二、使用异步定时器示例

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

1、makefile文件

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

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

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

2、asiotest2.h

[cpp] view plaincopy

#ifndef __ASIOTEST2__H__
#define __ASIOTEST2__H__
#include <iostream>
#include <boost/asio.hpp>
#include <boost/date_time/posix_time/posix_time.hpp>
void print(const boost::system::error_code& );
#endif

3、asiotest2.cpp

[cpp] view plaincopy

#include "asiotest2.h"
using namespace std;
using namespace boost;
void print(const boost::system::error_code& )
{
std::cout<<"hello,world!\n";
}
int main()
{
boost::asio::io_service io;
boost::asio::deadline_timer t(io,boost::posix_time::seconds(5));
t.async_wait(&print);
io.run();
return 0;
}

三、绑定参数到处理程序

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

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

2、头文件

[cpp] view plaincopy

#ifndef __ASIOTEST3__H__
#define __ASIOTEST3__H__
#include <iostream>
#include <boost/asio.hpp>
#include <boost/bind.hpp>
#include <boost/date_time/posix_time/posix_time.hpp>
#endif

3、CPP文件

[cpp] view plaincopy

#include "asiotest3.h"
void print(const boost::system::error_code&,
boost::asio::deadline_timer* t,int* count)
{
if(*count<5)
{
std::cout<<*count<<"\n";
++(*count);
t->expires_at(t->expires_at() + boost::posix_time::seconds(1));
t->async_wait(boost::bind(print,
boost::asio::placeholders::error,t,count));
}
}
int main()
{
boost::asio::io_service io;
int count=0;
boost::asio::deadline_timer t(io,boost::posix_time::seconds(1));
t.async_wait(boost::bind(print,boost::asio::placeholders::error,
&t,&count));
io.run();
std::cout<<"Final count is" <<count<<"\n";
return 0;
}

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

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

1、makefile 同上面示例

2、头文件

[cpp] view plaincopy

#ifndef __ASIOTEST4__H__
#define __ASIOTEST4__H__
#include <iostream>
#include <boost/asio.hpp>
#include <boost/bind.hpp>
#include <boost/date_time/posix_time/posix_time.hpp>
class printer
{
public:
printer(boost::asio::io_service& io)
:timer_(io,boost::posix_time::seconds(1)),
count_(0)
{
timer_.async_wait(boost::bind(&printer::print,this));
}
~printer()
{
std::cout<<"Final count is "<<count_<<"\n";
}
void print()
{
if(count_<5)
{
std::cout<<count_<<std::endl;
++count_;
timer_.expires_at(timer_.expires_at()+boost::posix_time::seconds(1));
timer_.async_wait(boost::bind(&printer::print,this));
}
}
private:
boost::asio::deadline_timer timer_;
int count_;
};

3、cpp文件

[cpp] view plaincopy

#include "asiotest4.h"
int main()
{
boost::asio::io_service io;
printer p(io);
io.run();
return 0;
}

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

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

1、makefile同上

2、头文件

[cpp] view plaincopy

#ifndef __ASIOTEST5__H__
#define __ASIOTEST5__H__
#include <iostream>
#include <boost/asio.hpp>
#include <boost/thread/thread.hpp>
#include <boost/bind.hpp>
#include <boost/date_time/posix_time/posix_time.hpp>
class printer
{
public:
printer(boost::asio::io_service& io):strand_(io),
timer1_(io,boost::posix_time::seconds(1)),
timer2_(io,boost::posix_time::seconds(1)),count_(0)
{
timer1_.async_wait(strand_.wrap(boost::bind(&printer::print1,this)));
timer2_.async_wait(strand_.wrap(boost::bind(&printer::print2,this)));
}
~printer()
{
std::cout<<"Final count is " <<count_<<std::endl;
}
void print1()
{
if(count_ < 10)
{
std::cout<<"Timer 1: "<<count_<<std::endl;
++count_;
timer1_.expires_at(timer1_.expires_at() + boost::posix_time::seconds(1));
timer1_.async_wait(strand_.wrap(boost::bind(&printer::print1,this)));
}
}
void print2()
{
if(count_ < 10)
{
std::cout<<"Timer 2: " <<count_<<std::endl;
++count_;
timer2_.expires_at(timer2_.expires_at() + boost::posix_time::seconds(1));
timer2_.async_wait(strand_.wrap(boost::bind(&printer::print2,this)));
}
}
private:
boost::asio::strand strand_;
boost::asio::deadline_timer timer1_;
boost::asio::deadline_timer timer2_;
int count_;
};
#endif

3、CPP文件

[cpp] view plaincopy

#include "asiotest5.h"
int main()
{
boost::asio::io_service io;
printer p(io);
boost::thread t(boost::bind(&boost::asio::io_service::run,&io));
io.run();
t.join();
return 0;
}

from:

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

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

声明：以上内容来自用户投稿及互联网公开渠道收集整理发布，本网站不拥有所有权，未作人工编辑处理，也不承担相关法律责任，若内容有误或涉及侵权可进行投诉：投诉/举报工作人员会在5个工作日内联系你，一经查实，本站将立刻删除涉嫌侵权内容。

联系
我们

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

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

看完仍有疑问？有类似问题直接问程序猿