c/c++ 多线程 boost的读写(reader-writer)锁

多线程 boost的读写(reader-writer)锁

背景:保护很少更新的数据结构时,c++标准库没有提供相应的功能。

例如:有个DNS条目缓存的map,基本上很少有更新,大部分都是读取,但是偶尔也会有更新,这种情况下,如果在读取的函数里加上std::mutex就过于悲观了,每次只能有一个线程读取,但是想要的效果是,多个线程可以同时读取。这个时候c++标准库就显得无能为力了。

boost库就能登场了。

boost有个共享锁:boost::shared_mutex和boost::shared_lock,用boost::shared_mutex代替std::mutex后,当有某一个线程读取dns时,就锁住了这个共享锁,当第二个线程也要读取时,这是第一个还没读完,也就是还没有解锁,如果用的是std::mutex的话,第二线程是无法进行读取的,但是换成boost::shared_mutex后,第二个线程也可以读取了,即便第一个读取的线程还有结束。

但是也有限制,读取操作可以多个线程同时读取,但是某个时间点,有个线程要更新dns,是否可以更新取决于,这个时间点是否有读的线程还没有结束。

1,如果读取的线程都结束了,也就是所有的共享锁都被解锁了,这时可以更新dns,并且在更新的同时,所有读取的线程都要被阻塞;

2,如果读取的线程还有任意一个没有结束了,也就是说并不是所有的共享锁都被解锁了,这时,更新的线程就会被阻塞,直到,所有的读取线程结束后,更新线程才会开始。

例子:

#include <map>
#include <string>
#include <thread>
#include <mutex>
#include <functional>
#include <boost/thread/shared_mutex.hpp> class dns_entry{ };
class dns_cache{
std::map<std::string, dns_entry> entries;
mutable boost::shared_mutex entry_mutex;
public:
dns_entry find_entry(std::string const& domain)const{
boost::shared_lock<boost::shared_mutex> lk(entry_mutex);
std::map<std::string, dns_entry>::const_iterator const it =
entries.find(domain);
return (it == entries.end()) ? dns_entry() : it->second;
}
void update_or_add_entry(std::string const& domain, dns_entry const& dns_details){
std::lock_guard<boost::shared_mutex> lk(entry_mutex);
entries[domain] = dns_details;
}
};
int main(){
dns_entry de;
dns_cache cache1, cache2, cache3;
std::thread t(&dns_cache::find_entry, std::ref(cache3), "aaa");
t.join();
std::thread t1(&dns_cache::update_or_add_entry, std::ref(cache1), "aaa", de);
t1.join();
std::thread t2(&dns_cache::find_entry, std::ref(cache2), "aaa");
t2.join();
}

github源代码

编译方法:

g++ -g boost-shared-mutex.3.13.cpp -std=c++11 -L/home/ys/Downloads/boost_1_68_0/stage/lib -lboost_thread -lboost_system -pthread

编译或者运行有问题的,请参考多线程 boost编译与运行的坑

小知识点:

1,下面的&X::open_connection的用法,必须有&和this,虽然open_connection的参数列表为空。因为open_connection是类的成员方法,所以就必须绑定到这个类的某个具体对象上,所以才必须有this和&。&是为了告诉编译器,这个方法不是类的static方法,而是类的成员方法。

2,std::ref(cache1),必须加上std::ref,否则编译不通过。原因:如果不使用std::ref,就会复制一个cache1,这明显不是想要的结果,想要的就是cache1,和bind函数原理一样。

std::thread t1(&dns_cache::update_or_add_entry, std::ref(cache1), "aaa", de);

c/c++ 学习互助QQ群:877684253

c/c++ 多线程 boost的读写(reader-writer)锁

本人微信:xiaoshitou5854

上一篇:c/c++ 多线程 ubuntu18.04 boost编译与运行的坑


下一篇:boost Shared Memory