C++多线程生产者-消费者问题

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

std::queue<int> buffer;
const int bufferSize = 10;
std::mutex mtx;
std::condition_variable producerCV, consumerCV;

void producer() {
    for (int i = 0; i < 20; ++i) {
        std::unique_lock<std::mutex> lock(mtx);
        producerCV.wait(lock, [] { return buffer.size() < bufferSize; });
        buffer.push(i);
        std::cout << "Produced: " << i << std::endl;
        lock.unlock();
        consumerCV.notify_one();
    }
}

void consumer() {
    for (int i = 0; i < 20; ++i) {
        std::unique_lock<std::mutex> lock(mtx);
        consumerCV.wait(lock, [] { return !buffer.empty(); });
        int data = buffer.front();
        buffer.pop();
        std::cout << "Consumed: " << data << std::endl;
        lock.unlock();
        producerCV.notify_one();
    }
}

int main() {
    std::thread producerThread(producer);
    std::thread consumerThread(consumer);
    producerThread.join();
    consumerThread.join();
    return 0;
}