仅在新数据上解锁线程（线程调用顺序）

Question

所以我有一个像这样的课程：

class mySafeData
{
public:
    void Set(int i) {
        boost::mutex::scoped_lock lock(myMutex);
        myData = i;
    }
    void Get( int& i)
    {
        boost::mutex::scoped_lock lock(myMutex);
        i = myData;
    }
private:
    int myData;
    boost::mutex myMutex;

};

我有一些线程在循环中调用Set，还有3 个线程在循环中调用Get。我需要让我的线程Get 一次和平数据不超过一次（这意味着它不能像我们Set 一样快地调用Get，这没关系，但它不能多次调用它 unteel new @ 987654327@ 被调用）。我的意思是在调用Get 的线程之后，它不能访问Get unteel Set 被执行。如何在如此简单的类中实现这样的事情，或者我的锁会默认为我做吗？

Answer 1

您需要condition variable。

请注意，即使您的阅读器线程获取与条件变量关联的互斥锁，它也需要检查条件是否已满足。也许让设置者在设置了一些东西后设置一个标志，而读者可以在阅读后重新设置它。

这需要改进，但可以完成工作。我通常会使用一个 std::deque ，这样作者就可以写必须锁定但不必等待线程读取它。

class mySafeData
{
public:
  mySafeData() : myData(0), changed( false )
  {
  }

  void Set(int i) 
  {
    boost::mutex::scoped_lock lock(myMutex);
    while( changed )
        myCondvar.wait( lock ); // wait for the data to be read

    myData = i; // set the data
    changed = true; // mark as changed
    myCondvar.notify_one(); // notify so a reader can process it
  }

  void Get( int& i)
  {
    boost::mutex::scoped_lock lock(myMutex);
    while( !changed )
    {
       myCondvar.wait( lock );
    } 
    i = myData;
    changed = false; // mark as read
    myCondvar.notify_one(); // notify so the writer can write if necessary
  }
 private:
   int myData;
   boost::mutex myMutex;
   boost::condition_variable myCondvar;
   bool changed;
};

Answer 2

您需要使用conditional variable 向其他线程发出对象状态变化的信号。