初级代码游戏的专栏介绍与文章目录-CSDN博客
我的github:codetoys,所有代码都将会位于ctfc库中。已经放入库中我会指出在库中的位置。
这些代码大部分以Linux为目标但部分代码是纯C++的,可以在任何平台上使用。
本文承接程序设计:C++11原子 写优先的读写锁(源码详解)-CSDN博客
上文已经列出了完整代码(上文最后),完整代码里面增加了操作跟踪,这里就讲解一下这部分是如何实现的。
目录
一、概述
二、关键实现
三、调试开关
四、其它说明
一、概述
操作跟踪有两个层面:进程层面和线程层面。
由于这个类设计为一个实体资源,不可移动,不可复制,多线程操作同一个对象实例,因此要跟踪就要在内部区别每个线程,所以用了线程存储对象。进程级的跟踪当然比较简单,用变量记录操作次数即可。
线程存储对象thread_local也是C++11新增的线程库的功能,只需要这么一个存储指示就可以把变量分线程存储。实际实现类似于一个线程相关的静态变量。
二、关键实现
进程级跟踪:
//进程操作计数,防止操作顺序错误mutable atomic<int> count_WLock{ 0 };mutable atomic<int> count_RLock{ 0 };
线程级跟踪:
//线程操作记录,防止线程操作错误并可用于中途让出再重新锁定struct thread_data{bool _isLocked{ false };//是否已经锁定,若已经锁定则不重复锁定bool _isWLock{ false };//是否是写锁定,当isLocked时有效。。。。。。};public:thread_data* getThreadData()const{thread_local map<CZS_RWMutex2 const*, thread_data > d;//通过对象地址区分不同的对象return &d[this];}
getThreadData()获取线程存储对象。因为这个变量相当于一个线程的静态变量,而我们可能会有多个互斥对象要操作,从一个静态变量入口如何区分不同对象?这就需要做成一个容器。
每个操作之后都会同时修改进程操作计数和线程操作计数:
void after_WLock()const{++count_WLock;getThreadData()->thread_data_WLock();}void after_RLock()const{++count_RLock;getThreadData()->thread_data_RLock();}void after_WUnLock()const{--count_WLock;getThreadData()->thread_data_UnLock();}void after_RUnLock()const{--count_RLock;getThreadData()->thread_data_UnLock();}
这样就可以在怀疑锁定操作出问题的时候输出状态来检查了。
编程有时候就像是个游戏。
三、调试开关
另外还有两个开关:
mutable bool isIngore{ false };//是否忽略,不锁定mutable bool isSafe{ false };//是否带有安全检查,确保操作序列正确
isIngore 忽略锁定,需要对比加锁不加锁的性能时忽略锁定即可,做一次布尔判断对性能是没有影响的(除非你的业务操作就是++i)。
isSafe 安全检查,开发、测试过程都应该打开,正式版本则关闭。
按照教科书上的理论,调试代码不应该出现在发行版中,应该以编译预处理的方式完全从二进制输出中删除。
但是实际中发现,由于内存布局的改变(来自调试版本自身的调试机制和我们自己的调试变量),会发生调试版正常而发行版却BUG了的情形。此种情形用调试版无法重现,调式的时候就比较头疼
所以我选择这样做:在发行版中仍然保留我们自己的调试代码,通过一个全局开关启用或关闭。
当然,这样做是以客观条件限制为基础的:没有严格的测试环节,基本靠自己;程序大小无关紧要,没人在意。
四、其它说明
由于这个类是重写的基于信号量的版本,所以接口也与信号量版本保持一致,所以在部分接口中是把mySEM对象视同信号量 ID的:
//创建新信号量bool Create(mySEM * id){if (isSafe){if (0 != count_WLock || 0 != count_RLock){*(int*)&m_errid = __LINE__;(*(stringstream*)&m_errmsg).str("");*(stringstream*)&m_errmsg << "sem " << sem_id << " 已经锁定,需要先解锁";return false;}}sem_id = id;if (nullptr == sem_id){m_errid = __LINE__;m_errmsg.str("");m_errmsg << errno2str();return false;}sem_id->init();return true;}
这个功能其实就是接受一个mySEM指针,然后初始化而已。
(这里是结束)