boost::shared

前一篇介绍的条件变量可以进行进程间通信，用来实现生产者/消费者模型。今天介绍的共享互斥量用来实现缓冲区读写模型，与生产者/消费者模型不同的地方是，消费者消费产品后，被消费的产品就不存在了，所以消费者线程也要互斥运行；而缓冲区读取线程读取数据后不删除数据，多个线程可以并行读取。这时使用条件变量也不合适了，就要使用共享互斥变量了。

共享互斥量，顾名思义，既共享，也互斥，读线程之间共享读取数据，使用shared_lock类锁定shared_mutex变量；写线程之间需要独占缓冲区，必须互斥运行，使用unique_lock类锁定shared_mutex变量。这与互斥变量mutex的使用方法不一样，mutex类内部提供了一种lock_guard类即scope_lock类，因此可以用

[cpp] view plaincopy print?

mutex::scope_lock lock(mu);

这样的形式来锁定互斥量，而share_mutex类没有提供这种内部定义的lock_guard类，所以需要直接使用lock_guard对象，语法如下代码：

[cpp] view plaincopy print?

shared_mutex rw_mu;
unique_lock<shared_mutex> ul(rw_mu);
shared_lock<shared_mutex> sl(rw_mu);

下面是《指南》上的例子：

[cpp] view plaincopy print?

private:
int m_x;
shared_mutex rw_mu;
public:
rw_data():m_x(0){}
void write()
{
unique_lock<shared_mutex> ul(rw_mu);
++m_x;
}
void read(int& x)
{
shared_lock<shared_mutex> sl(rw_mu);
x = m_x;
}
};
void writer(rw_data& d)
{
for(int i = 0; i < 20; ++i)
{
this_thread::sleep(posix_time::millisec(10));
d.write();
}
}
void reader(rw_data& d, mutex& io_mu)
{
int x;
for(int i = 0; i < 10; ++i)
{
this_thread::sleep(posix_time::millisec(5));
d.read(x);
mutex::scoped_lock lock(io_mu);
std::cout << "reader:" << x << std::endl;
}
}
int main()
{
rw_data d;
thread_group pool;
mutex io_mu;
pool.create_thread(bind(reader,ref(d), ref(io_mu)));
pool.create_thread(bind(reader,ref(d), ref(io_mu)));
pool.create_thread(bind(reader,ref(d), ref(io_mu)));
pool.create_thread(bind(reader,ref(d), ref(io_mu)));
pool.create_thread(bind(writer,ref(d)));
pool.create_thread(bind(writer,ref(d)));
pool.join_all();
return 0;
}

boost::shared_mutex相关推荐

boost::shared_mutex相关的测试程序
boost::shared_mutex相关的测试程序实现功能 C++实现代码实现功能 boost::shared_mutex相关的测试程序 C++实现代码 #define BOOST_THREAD ...
Boost读写锁：shared_mutex
shared_mutex即读写锁,不同与我们常用的独占式锁mutex,shared_mutex是共享与独占共存的锁,实现了读写锁的机制,即多个读线程一个写线程,通常用于对于一个共享区域的读操作比较频繁 ...
Boost库之circular_buffer
Boost库之circular_buffer 原文:http://blog.csdn.net/byxdaz/article/details/71631470 Boost.Circular_buffer ...
boost asio 异步实现tcp通讯
一.前言 boost asio可算是一个简单易用,功能又强大可跨平台的C++通讯库,效率也表现的不错,linux环境是epoll实现的,而windows环境是iocp实现的.而tcp通讯是项目当中经常 ...
（十一）boost库之多线程间通信
1.互斥锁在编程中,引入了对象互斥锁的概念,来保证共享数据操作的完整性.每个对象都对应于一个可称为" 互斥锁" 的标记,这个标记用来保证在任一时刻,只能有一个线程访问该对象. # ...
【Boost】boost库中thread多线程详解2——mutex与lock
1. mutex对象类 mutex类主要有两种:独占式与共享式的互斥量. ▲ 独占式互斥量: mutex: 独占式的互斥量,是最简单最常用的一种互斥量类型 try_mutex: 它是mutex的同义词 ...
9 C++ Boost 多线程,线程同步
线程的创建 boost_thread,boost_system 多线程的创建线程的参数传递线程的创建方式线程的join 加入join,回收线程线程中断线程中断2, 线程组 boost 线程的死 ...
c++ boost多线程学习（一）
本次学习相关资料如下: Boost C++ 库第 6 章多线程(大部分代码的来源) Boost程序库完全开发指南 - 深入C++"准"标准库第三版罗剑锋著头文件: #in ...
使用boost模板函数实现读写锁
介绍 shared_mutex即读写锁,不同与我们常用的独占式锁mutex,shared_mutex是共享与独占共存的锁,实现了读写锁的机制,即多个读线程一个写线程,通常用于对于一个共享区域的读操作比 ...

boost::shared_mutex

boost::shared_mutex相关推荐

最新文章

热门文章