Boost.Asio 介绍--之二
上一篇介绍了Boost.Asio的一些特性，但是相对抽象和离散，这篇博客从Boost.Asio的基础知识一步步深入，读完之后对Boost.Asio会有全面的了解和掌握。Boost.Asio通过采用C++以及Boost库的语法特性，提供跨平台的异步网络IO能力。因此使用Boost.Asio需要基本的网络知识，C++、Boost知识。
io_service是Boost.Asio的核心类，run()方法是它的重要方法之一，后续会陆续介绍到其dispatch,post,stop,reset等重要方法。run()方法的作用是阻塞程序直到所有的工作都完成，所有的handler都dispatch了；或者当调用stop方法时，run()方法也会不再阻塞下去。下面是一个说明run()方法的示例程序:
#include <boost/asio.hpp>
#include <iostream>
int main( int argc, char * argv[] )
{
boost::asio::io_service io_service;
io_service.run();
std::cout << "Do you reckon this line displays?" << std::endl;
return 0;
}通常我们不希望程序自动退出，因为可能还有其它任务需要处理，更多的时候希望控制程序何时退出，Boost.Asio考虑到了这点，看下面的例子：
#include <boost/asio.hpp>
#include <iostream>
int main( int argc, char * argv[] )
{
boost::asio::io_service io_service;
boost::asio::io_service::work work( io_service );
io_service.run();
std::cout << "Do you reckon this line displays?" << std::endl;
return 0;
}
#include <boost/asio.hpp>
#include <iostream>
int main( int argc, char * argv[] )
{
boost::asio::io_service io_service;
for( int x = 0; x < 42; ++x )
{
io_service.poll();
std::cout << "Counter: " << x << std::endl;
}
return 0;
}程序输出为0到41然后退出；如果这时也给io_service工作---work，而不reset,结果会是怎样呢？
#include <boost/asio.hpp>
#include <iostream>
int main( int argc, char * argv[] )
{
boost::asio::io_service io_service;
boost::asio::io_service::work work( io_service );
for( int x = 0; x < 42; ++x )
{
io_service.poll();
std::cout << "Counter: " << x << std::endl;
}
return 0;
}
程序仍然输出为0到41然后退出。这是因为poll方法是非阻塞的，它只是检查当前工作队列中是否有就绪的，有就执行，然后立刻返回。在实际项目中，for循环一般是某种形式的事件循环。上面这个例子也说明了Boost.Asio的事件处理机制，work 对象给io_service对象提供工作内容，但如果在事件处理handler中再给io_service提供work,那么work将会递归无穷的产生，poll将永远不会结束。所以work的添加是在事件处理函数外部进行的。
也就是说可以根据程序的设置，选择采用run()方法还是poll方法来运行程序。当然也有一些变体，run_one(),poll_one(),它们分别表示每次只执行一个事件处理handler，这在并发时能够很好的控制程序。
从io_service.run()从io_service中删除work会使io_service.run()结束阻塞状态，但是io_service并没有这样的成员函数，这时必须通过智能指针来实现：通过reset智能指针来删除智能指针所指向的对象，这样就可以很优雅的移除work了。
#include <boost/asio.hpp>
#include <boost/shared_ptr.hpp>
#include <iostream>
int main( int argc, char * argv[] )
{
boost::asio::io_service io_service;
boost::shared_ptr< boost::asio::io_service::work > work(
new boost::asio::io_service::work( io_service )
);
work.reset();
io_service.run();
std::cout << "Do you reckon this line displays?" << std::endl;
return 0;
}
void WorkerThread()
{
std::cout << "Thread Start\n";
io_service.run();
std::cout << "Thread Finish\n";
}
int main( int argc, char * argv[] )
{
boost::shared_ptr< boost::asio::io_service::work > work(
new boost::asio::io_service::work( io_service )
);
std::cout << "Press [return] to exit." << std::endl;
boost::thread_group worker_threads;
for( int x = 0; x < 4; ++x )
{
worker_threads.create_thread( WorkerThread );
}
std::cin.get();
io_service.stop();
worker_threads.join_all();
return 0;
}