boost庫學習隨記六：使用同步定時器、異步定時器、bind、成員函數回調處理、多線程的同步處理示例等

2016-09-28 00:00:00 廣州睿豐德信息科技有限公司閱讀

睿豐德科技專注RFID識別技術和條碼識別技術與管理軟件的集成項目。質量追溯系統、MES系統、金蝶與條碼系統對接、用友與條碼系統對接

一、使用同步定時器

這個示例程序通過展示如何在一個定時器執行一個阻塞等待。

[cpp] view plain copy

//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 plain copy

//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 plain copy

//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 plain copy

#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 plain copy

#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 plain copy

#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 plain copy

#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 plain copy

#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 plain copy

#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 plain copy

#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 plain copy

#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 RFID管理系統集成商 RFID中間件條碼系統中間層物聯網軟件集成

上一條 gdb圖形化調試工具總結
下一條 C++ int與string的轉化