1

我有一个包含 boost::mutex 作为私有成员的类。当您调用其公共函数之一时，它会被锁定，并在函数退出时解锁。这是为了提供对对象内部的同步访问。

class StringDeque
{
  boost::mutex mtx;
  std::deque<string> string_deque;
public:
  StringDeque() { }

  void addToDeque(const string& str_to_add)
  {
    boost::lock_guard<boost::mutex> guard(mtx);
    string_deque.push(str_to_add);
  }

  string popFromDeque()
  {
    boost::lock_guard<boost::mutex> guard(mtx);
    string popped_string = string_deque.front();
    string_deque.pop();
    return popped_string;
  }
};

这个类并不是特别有用，但我只是在玩互斥锁和线程。

我有一个 main()，它还定义了另一个函数，该函数从类中弹出字符串并在线程中打印它们。它将重复 10 次，然后从函数返回。再一次，这纯粹是为了测试目的。它看起来像这样：

void printTheStrings(StringDeque& str_deque)
{
    int i = 0;
    while(i < 10)
    {
      string popped_string = str_deque.popFromDeque();
      if(popped_string.empty())
      {
        sleep(1);
        continue;
      }
      cout << popped_string << endl;
      ++i;
    }
}

int main()
{
  StringDeque str_deque;
  boost::thread the_thread(printTheStrings, str_deque);
  str_deque.addToDeque("Say your prayers");
  str_deque.addToDeque("Little One");
  str_deque.addToDeque("And Don't forget My Son");
  str_deque.addToDeque("To include everyone");
  str_deque.addToDeque("I tuck you in");
  str_deque.addToDeque("Warm within");
  str_deque.addToDeque("Keep you free from sin");
  str_deque.addToDeque("Until the sandman he comes");
  str_deque.addToDeque("Sleep with one eye open");
  str_deque.addToDeque("Gripping your pillow tight");
  the_thread.join();
}

我不断得到的错误是 boost::mutex 是不可复制的。printTheStrings() 函数需要一个引用，所以我有点困惑为什么它试图复制对象。

我已经对此进行了一些阅读，并且我一直在阅读的一个解决方案是使 boost::mutex 成为对象的静态私有成员。但是，这违背了我的互斥锁的目的，因为我希望它基于对象而不是类变量。

这只是对互斥锁的不当使用吗？我是否应该重新考虑整个应用程序？

编辑：

我刚刚发现 condition_variable 应该更好地服务于我的目的，让线程等待直到双端队列中实际存在某些东西，然后再醒来从双端队列中弹出并打印它。我看到的所有示例都在全局范围内定义了这些互斥锁和 condition_variable 对象。这似乎非常......在我看来不是面向对象的。甚至直接来自 Boost 本身的示例也表明它是以这种方式完成的。这真的是其他人使用这些对象的方式吗？

4

1 回答 1

2

你是正确printToString的，StringQueue通过引用。您的问题是boost::thread按价值衡量其论点。要强制它通过引用获取参数，您需要将内容修改为：

boost::thread the_thread(printTheStrings, boost::ref(str_deque));

顺便说一句，从 C++11 开始，线程是标准库的一部分。你可能应该使用std::thread instead

于 2016-11-08T09:31:52.427 回答