c++ - 生产者/消费者，消费者线程从未执行过

Question

创建了一个具有生产者线程和消费者线程的程序。

生产者线程每隔一秒不断地插入一个栈，栈被互斥体保护。

消费者线程不断从栈中弹出。

意外的行为是，生产者线程一直在运行，而消费者线程永远没有机会弹出堆栈。

我该如何继续调查这个问题？非常感谢。

#include <stack>
#include <chrono>

#include <thread>
#include <mutex>
#include <condition_variable>
#include <iostream>


std::mutex mtx;
std::stack<int> the_stack;

void producer(const int id)
{
  while(1)
  {
    mtx.lock();
    the_stack.push(0);
    std::cout << "Producer " << id << " push" << std::endl;
    std::this_thread::sleep_for(std::chrono::seconds(1));
    mtx.unlock();
  }
}//producer


void consumer(const int id)
{
  while(1)
  {
    mtx.lock();
    if (!the_stack.empty())
    {
      std::cout << "Consumer " << id << " pop" << std::endl;
      the_stack.pop();
    }
    mtx.unlock();
  }
}//consumer


int main()
{
  std::thread thread_0(producer, 0);
  std::thread consum_0(consumer, 0);

  thread_0.join();
  consum_0.join();

  return 0;
}//main;

Answer 1

生产者在持有互斥锁的同时正在休眠。这很难让消费者有机会锁定互斥量。

如果将 sleep 语句放在互斥保护区之外，它将按预期工作。

void producer(const int id)
{
  while(1)
  {
    ....
    mtx.unlock();
    std::this_thread::sleep_for(std::chrono::seconds(1)); // below the unlock operation
  }