首页 > 代码库 > skynet源码学习 - 读写锁
skynet源码学习 - 读写锁
skynet 利用内置的原子操作来实现的一个读写锁,重点是理解 ”full memory barrier“ ,UNPv2 中利用互斥和条件变量实现的读写锁。前者是在硬件支持的情况下,显得简单明了,站的层次不一样。
源码贴出来:
struct rwlock { int write; int read; }; static inline void rwlock_init(struct rwlock *lock) { lock->write = 0; lock->read = 0; } static inline void rwlock_rlock(struct rwlock *lock) { for (;;) { // isuued a full memory barrier. This typically means that operations issued // prior to the barrier are guaranteed to be performed before operations issued after the barrier. while(lock->write) { __sync_synchronize(); } __sync_add_and_fetch(&lock->read,1); // 在给nreaders + 1 之后再次检查是否有写入者,有的话此次读锁请求失败 if (lock->write) { __sync_sub_and_fetch(&lock->read,1); } else { break; } } } static inline void rwlock_wlock(struct rwlock *lock) { // 如果没有写者,__sync_lock_test_and_set会返回0,表示此次请求写锁成功; // 否则表示有其它写者,则空转 while (__sync_lock_test_and_set(&lock->write,1)) {} // 在开始写入之前发现有读者进入,则要等到前面的操作完成 while(lock->read) { __sync_synchronize(); } } static inline void rwlock_wunlock(struct rwlock *lock) { __sync_lock_release(&lock->write); } static inline void rwlock_runlock(struct rwlock *lock) { __sync_sub_and_fetch(&lock->read,1); }
写个简单的程序跑下:
skynet源码学习 - 读写锁
声明:以上内容来自用户投稿及互联网公开渠道收集整理发布,本网站不拥有所有权,未作人工编辑处理,也不承担相关法律责任,若内容有误或涉及侵权可进行投诉: 投诉/举报 工作人员会在5个工作日内联系你,一经查实,本站将立刻删除涉嫌侵权内容。