根据你提供的代码,我注意到可能会有一些问题导致编译错误。以下是我发现的两个问题和解决方法:
condition_variable
的命名冲突:在 C++ 中,condition_variable
是一个模板类,它的完整名称应该是 std::condition_variable
。然而,你的代码中使用了全局的 condition_variable
对象名字与类名相同,这可能导致命名冲突。解决方法是为 condition_variable
对象添加命名空间前缀 std::
,即 std::condition_variable producer_cv, consumer_cv;
。
wait()
和 notify_one()
的调用方式:wait()
和 notify_one()
方法需要在持有互斥锁的情况下调用。在你的代码中,你使用了 unique_lock
对象 lock
来持有互斥锁,但是你没有在调用 wait()
和 notify_one()
时将 lock
传递给它们。解决方法是将 lock
作为参数传递给 wait()
和 notify_one()
方法,即 producer_cv.wait(lock);
和 consumer_cv.wait(lock);
。
修正后的代码如下:
#include <iostream>
#include <thread>
#include <mutex>
#include <condition_variable>
const int kBufferSize = 5; // 仓库容量
int buffer[kBufferSize]; // 仓库
int in = 0; // 下一次生产者放入的位置
int out = 0; // 下一次消费者取出的位置
std::mutex mtx; // 用于保护临界区
std::condition_variable producer_cv, consumer_cv; // 用于同步生产者和消费者线程
void producer() {
for (int i = 1; i <= kBufferSize; ++i) {
std::unique_lock<std::mutex> lock(mtx);
// 等待仓库不满
while ((in + 1) % kBufferSize == out) {
producer_cv.wait(lock);
}
// 生产物品并放入仓库
buffer[in] = i;
in = (in + 1) % kBufferSize;
// 唤醒消费者
consumer_cv.notify_one();
}
}
void consumer() {
for (int i = 1; i <= kBufferSize; ++i) {
std::unique_lock<std::mutex> lock(mtx);
// 等待仓库不空
while (in == out) {
consumer_cv.wait(lock);
}
// 从仓库取出物品并消费
int item = buffer[out];
out = (out + 1) % kBufferSize;
// 唤醒生产者
producer_cv.notify_one();
// 输出消费的物品
std::cout << "Consumer consumed item: " << item << std::endl;
}
}
int main() {
std::thread producer_thread(producer);
std::thread consumer_thread(consumer);
producer_thread.join();
consumer_thread.join();
return 0;
}
请尝试使用修正后的代码编译并运行,看看是否解决了你遇到的问题。如果还有其他问题,请提供具体的错误信息,我将尽力帮助你解决。