C++阻塞队列线程

Question

我编写了一个简单的类，我计划将其扩展为客户端套接字编程应用程序的一部分。类涉及一个BlockingQueue（我从这里复制了代码：相当于Java的BlockingQueue的C++）。当我创建了下面的包装类的一个实例后，我打算让它生成一个单独的线程，该线程只需执行BlockingQueue上阻塞的printer（）函数，直到有一个或多个字符串可用，然后它只需将字符串打印到控制台窗口。在我的预期应用程序中，控制台打印将被一个更耗时的网络功能所取代，该功能涉及发送数据包、等待接收方的确认和一些错误处理。但现在，我只是想让它在不崩溃的情况下打印到控制台窗口。当我执行时，它会在打印任何东西之前立即崩溃。

#include <iostream>
#include <thread>
#include "BlockingQueue.h"

using namespace std;

class Wrapper {

  public:
      Wrapper() {
          threadObj1 = thread(&Wrapper::printer, this);
      }

      void submitStringToWrite(string str) {
          queue.push(str);
      }

      void printer() {
          while(true) {
              string str = queue.pop();
              cout << str.c_str() << endl;
          }
      }

    private:
        BlockingQueue<string> queue;
        std::thread threadObj1;
};

int main() {
  Wrapper *w = new Wrapper();
  w->submitStringToWrite("One");
  w->submitStringToWrite("Two");
  w->submitStringToWrite("Three");
  system("pause");
  return 0;
}

下面是阻塞队列的实现，借用了上面的链接：

#include <mutex>
#include <condition_variable>
#include <deque>

template <typename T>
class BlockingQueue
{
private:
    std::mutex              d_mutex;
    std::condition_variable d_condition;
    std::deque<T>           d_queue;
public:
    void push(T const& value) {
        {
            std::unique_lock<std::mutex> lock(this->d_mutex);
            d_queue.push_front(value);
        }
        this->d_condition.notify_one();
    }
    T pop() {
        std::unique_lock<std::mutex> lock(this->d_mutex);
        this->d_condition.wait(lock, [=]{ return !this->d_queue.empty(); });
        T rc(std::move(this->d_queue.back()));
        this->d_queue.pop_back();
        return rc;
    }
};

Answer 1

@谢夫在评论区的回答是正确的。我修复了上面的代码。现在起作用了。我无法在两天内结束这个问题。主持人们，你们可以继续结束这个问题了。