Boost::asio io_service 实现分析
io_service的作用
io_servie 实现了一个任务队列,这里的任务就是void(void)的函数。Io_servie最常用的两个接口是post和run,post向任务队列中投递任务,run是执行队列中的任务,直到全部执行完毕,并且run可以被N个线程调用。Io_service是完全线程安全的队列。
Io_servie的接口
提供的接口有run、run_one、poll、poll_one、stop、reset、dispatch、post,最常用的是run、post、stop
Io_servie 实现代码的基本类结构:
l Io_servie是接口类,为实现跨平台,采用了策略模式,所有接口均有impl_type实现。根据平台不同impl_type分为
n win_iocp_io_service Win版本的实现,这里主要分析Linux版本。
n task_io_service 非win平台下的实现,其代码结构为:
u detail/task_io_service_fwd.hpp 简单声明task_io_service名称
u detail/task_io_service.hpp 声明task_io_service的方法和属性
u detail/impl/task_io_service.ipp 具体实现文件
u 队列中的任务类型为opertioan,原型其实是typedef task_io_service_operation operation,其实现文件在detail/task_io_service_operation.hpp中,当队列中的任务被执行时,就是task_io_service_operation:: complete被调用的时候。
Io_servie::Post方法的实现
Post向队列中投递任务,然后激活空闲线程执行任务。其实现流程如下:
l Post接收handler作为参数,实际上是个仿函数,通过此仿函数构造出completion_handler对象,completion_handler继承自operation。然后调用post_immediate_completion。
l post_immediate_completion首先将outstanding_work_增加,然后调用post_deferred_completion。
l post_deferred_completion首先加锁将任务入列,然后调用wake_one_thread_and_unlock
l wake_one_thread_and_unlock尝试唤醒当前空闲的线程,其实现中特别之处在于,若没有空闲线程,但是有线程在执行task->run,即阻塞在epoll_wait上,那么先中断epoll_wait执行任务队列完成后再执行epoll_wait。
l first_idle_thread_维护了所有当前空闲线程,实际上使用了Leader/Follower模式,每次唤醒时只唤醒空闲线程的第一个。
Io_servie::run方法的实现
Run方法执行队列中的所有任务,直到任务执行完毕。
l run方法首先构造一个idle_thread_info,和first_idle_thread_类型相同,即通过first_idle_thread_将所有线程串联起来,它这个串联不是立即串联的,当该线程无任务可做是加入到first_idle_thread_的首部,有任务执行时,从first_idle_thread_中断开。这很正常,因为first_idle_thread_维护的是当前空闲线程。
l 加锁,循环执行do_one方法,直到do_one返回false
l do_one每次执行一个任务。首先检查队列是否为空,若空将此线程追加到first_idle_thread_的首部,然后阻塞在条件变量上,直到被唤醒。
l 当被唤醒或是首次执行,若stopped_为true(即此时stop方法被调用了),返回0
l 队列非空,pop出一个任务,检查队列无任务那么简单的解锁,若仍有,调用wake_one_thread_and_unlock尝试唤醒其他空闲线程执行。然后执行该任务,返回1.
l 实际上在执行队列任务时有一个特别的判断if (o == &task_operation_),那么将会执行task_->run,task_变量类型为reactor,在linux平台实现为epoll_reactor,实现代码文件为detail/impl/epoll_reactor.ipp,run方法实际上执行的是epoll_wait,run阻塞在epoll_wait上等待事件到来,并且处理完事件后将需要回调的函数push到io_servie的任务队列中,虽然epoll_wait是阻塞的,但是它提供了interrupt函数,该interrupt是如何实现的呢,它向epoll_wait添加一个文件描述符,该文件描述符中有8个字节可读,这个文件描述符是专用于中断epoll_wait的,他被封装到select_interrupter中,select_interrupter实际上实现是eventfd_select_interrupter,在构造的时候通过pipe系统调用创建两个文件描述符,然后预先通过write_fd写8个字节,这8个字节一直保留。在添加到epoll_wait中采用EPOLLET水平触发,这样,只要select_interrupter的读文件描述符添加到epoll_wait中,立即中断epoll_wait。很是巧妙。!!!实际上就是因为有了这个reactor,它才叫io_servie,否则就是一个纯的任务队列了。
l Run方法的原则是:
n 有任务立即执行任务,尽量使所有的线程一起执行任务
n 若没有任务,阻塞在epoll_wait上等待io事件
n 若有新任务到来,并且没有空闲线程,那么先中断epoll_wait,先执行任务
n 若队列中有任务,并且也需要epoll_wait监听事件,那么非阻塞调用epoll_wait(timeout字段设置为0),待任务执行完毕在阻塞在epoll_wait上。
n 几乎对线程的使用上达到了极致。
n 从这个函数中可以知道,在使用ASIO时,io_servie应该尽量多,这样可以使其epoll_wait占用的时间片最多,这样可以最大限度的响应IO事件,降低响应时延。但是每个io_servie::run占用一个线程,所以io_servie最佳应该和CPU的核数相同。
Io_servie::stop的实现
l 加锁,调用stop_all_threads
l 设置stopped_变量为true,遍历所有的空闲线程,依次唤醒
l task_interrupted_设置为true,调用task_的interrupt方法
l task_的类型为reactor,在run方法中已经做了分析
Boost::asio io_service 实现分析相关推荐
- boost asio io_service与 strand 分析
1: io_service 与 strand 的关系是什么? 2: strand : /// Provides serialised handler execution. 能够保证线程安全,同时被po ...
- boost asio io_service学习笔记
转自:http://hi.baidu.com/jrckkyy/blog/item/e86835d61e60722506088b6a.html 构造函数 构造函数的主要动作就是调用CreateIoCom ...
- boost::asio::io_service的stop()和reset()和stopped()函数
◆boost::asio::io_service使用时的注意事项: ①请让boost::asio::io_service和boost::asio::io_service::work搭配使用. ②想让e ...
- Boost.ASIO简要分析-4 多线程
4. 多线程 一般情况下,服务端开启一条线程做io_service::run()工作就足够了.但是,有些情况下可能会变得很糟糕. 从之前的分析,我们知道异步操作的一个关键步骤就是io_service回 ...
- boost.asio系列——io_service
IO模型 io_service对象是asio框架中的调度器,所有异步io事件都是通过它来分发处理的(io对象的构造函数中都需要传入一个io_service对象). asio::io_service i ...
- boost asio 应用方法学(二)——深入框架
要用好它,就必须先了解它,而且不能停止于表面,必须深入到内部.而了解一件事物,先要了解它的框架,再了解它的细节.了解了框架,我们就有了提纲挈领的认识. 关于 boost asio 框架结构,在其文档中 ...
- 基于boost asio实现的支持ssl的通用socket框架
情景分析 现已存在一个可用稳定的异步客户端类http_client_base,该类基于boost asio实现了连接服务器,发送请求,获取响应和解析http数据等操作,该类的大致实现框架如下 ...
- Boost asio 官方教程简介
1. 概述 本章介绍了 Boost C++ 库 Asio,它是异步输入输出的核心. 名字本身就说明了一切:Asio 意即异步输入/输出. 该库可以让 C++ 异步地处理数据,且平台独立. 异步数据处理 ...
- boost asio ——深入框架
要用好它,就必须先了解它,而且不能停止于表面,必须深入到内部.而了解一件事物,先要了解它的框架,再了解它的细节.了解了框架,我们就有了提纲挈领的认识. 关于 boost asio 框架结构,在其文档中 ...
最新文章
- 机器学习知识体系(强烈推荐)
- 信息安全复习2关于网络安全
- 非递归快速排序php,快排序的非递归实现(原创)
- 数据可视化项目落地复盘
- 2013/01/04作业raid+lvm+quota
- devexpress 创建窗口句柄时出错_MATLAB函数句柄
- 企业管理软件解决方案 出售 :针对华东区中小企业订单仓储管理流程
- UVA344 UVALive5452 Roman Digititis【Ad Hoc】
- 记一次调试YOLOv5+DeepSort车辆跟踪项目的经过
- python入门心得_python学习心得:如何入门
- Tbase数据库入坑记
- 华为管理学案例分析_华为战略管理案例分析.docx
- MacOS中的剪切快捷键
- 虚幻引擎图文笔记:使用布料模拟(Cloth Simulation)系统制作一面可以随风飘动的旗帜(更新)
- shell 中匹配正则 字符串处理【整理版】
- Policy Evaluation收敛性、炼丹与数学家
- 小程序实现实名、支付及签约
- python中合法的赋值语句y=y+1_关于Python赋值语句,以下选项中不合法的是 _________ 。_学小易找答案...
- 《追风筝的人》观后感
- php小数点问题,php--小数点问题 - osc_m4jd02jn的个人空间 - OSCHINA - 中文开源技术交流社区...
热门文章
- Chrome插件HostAdmin
- 哆啦a梦简单图画python编程_[python]画哆啦A梦,Python,绘制
- python中保留两位小数的编写程序_Python中保留两位小数的几种方法
- java基础入门传智播客 源码_Java-_2020年版Java零基础视频教程(Java 0基础,Java初学入门)魔鬼讲师老杜出品...
- Java项目:前台+后台精品图书管理系统(java+SSM+jsp+mysql+maven)
- Jrebel 热部署插件的使用和破解
- Angular 可观察对象(Observable)
- python数据库建表_mysql数据表如何创建
- 折线图表动画(历史进程效果)
- Java并发面试,幸亏有点道行,不然又被忽悠了