Boost条件变量condition_variable_any

Posted

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了Boost条件变量condition_variable_any相关的知识,希望对你有一定的参考价值。

  Boost条件变量可以用来实现线程同步,它必须与互斥量配合使用。使用条件变量实现生产者消费者的简单例子如下,需要注意的是cond_put.wait(lock)是在等待条件满足。如果条件不满足,则释放锁,将线程置为waiting状态,继续等待;如果条件满足,则重新获取锁,然后结束wait,继续向下执行。

#include "stdafx.h"
#include <stack>
#include <boost/bind/bind.hpp>
#include <boost/thread.hpp>
#include <boost/thread/lock_factories.hpp>
using namespace std;
class Buffer
{
private:
    boost::mutex mu;

    boost::condition_variable_any cond_put;
    boost::condition_variable_any cond_get;
    int un_read, capacity;

    std::stack<int> m_stk;
    bool isFull()
    {
        return un_read == capacity;
    }
    bool isEmpty()
    {
        return un_read == 0;
    }
public:
    Buffer(size_t n):un_read(0), capacity(n) {}

    void put(int x)
    {
        {
            auto lock = make_unique_lock(mu);
            for (; isFull(); )
            {
                cout << "Full waiting"<<endl;
                cond_put.wait(lock);
            }
            m_stk.push(x);
            ++un_read;
        }
        cond_get.notify_one();
    }

    void get(int *x)
    {
        {
            auto lock = make_unique_lock(mu);
            for (; isEmpty(); )
            {
                cout<<"Empty waiting..."<<endl;
                cond_get.wait(lock);
            }
            --un_read;
            *x = m_stk.top();
            m_stk.pop();
        }
        cond_put.notify_one;
    }

};

Buffer buf(5);
void Producer(int n)
{
    for (int i=0; i<n; i++)
    {
        cout<< "Putting "<<i<<endl;
        buf.put(i);
    }
}

void Consumer(int n)
{
    int x;
    for (int i=0; i<n; i++)
    {
        buf.get(&x);
        cout<<"Getting "<<x<<endl;
    }
}

int main()
{
    boost::thread_group tg;
    tg.create_thread(bind(Producer, 20));

    tg.create_thread(bind(Consumer, 10));
    tg.create_thread(bind(Consumer, 10));

    tg.join_all();

    return 0;
}

  

以上是关于Boost条件变量condition_variable_any的主要内容,如果未能解决你的问题,请参考以下文章

boost asio 和条件变量——奇怪的输出

在已锁定的互斥体上使用 boost::interprocess 条件变量

C++ 条件变量范围

需要对条件变量寻求的互斥保护(原子)赋值吗?

等待条件的线程的有序通知(C++,boost)

为啥 autoconf 脚本中的条件在变量前加上“x”?