silencesilent6 2023-12-29 15:01 采纳率: 0%
浏览 11

为什么编译出来会这样报错啊,这是什么意思啊

img

img




```题目是
用程序实现生产者—消费者问题。具体问题描述:
一个仓库可以存放K件物品。生产者每生产一件产品,将产品放入仓库,仓库满了就停止生产。消费者每次从仓库中去一件物品,然后进行消费,仓库空时就停止消费。
用的是c++

代码是这样的
#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;
}
  • 写回答

2条回答 默认 最新

  • 爱编程的鱼 2023-12-29 15:17
    关注

    根据你提供的代码,我注意到可能会有一些问题导致编译错误。以下是我发现的两个问题和解决方法:

    1. condition_variable 的命名冲突:在 C++ 中,condition_variable 是一个模板类,它的完整名称应该是 std::condition_variable。然而,你的代码中使用了全局的 condition_variable 对象名字与类名相同,这可能导致命名冲突。解决方法是为 condition_variable 对象添加命名空间前缀 std::,即 std::condition_variable producer_cv, consumer_cv;

    2. 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;
    }
    

    请尝试使用修正后的代码编译并运行,看看是否解决了你遇到的问题。如果还有其他问题,请提供具体的错误信息,我将尽力帮助你解决。

    评论

报告相同问题?

问题事件

  • 创建了问题 12月29日

悬赏问题

  • ¥15 phython如何实现以下功能?查找同一用户名的消费金额合并—
  • ¥15 孟德尔随机化怎样画共定位分析图
  • ¥18 模拟电路问题解答有偿速度
  • ¥15 CST仿真别人的模型结果仿真结果S参数完全不对
  • ¥15 误删注册表文件致win10无法开启
  • ¥15 请问在阿里云服务器中怎么利用数据库制作网站
  • ¥60 ESP32怎么烧录自启动程序
  • ¥50 html2canvas超出滚动条不显示
  • ¥15 java业务性能问题求解(sql,业务设计相关)
  • ¥15 52810 尾椎c三个a 写蓝牙地址