C++多线程学习笔记004简单的Producer和Consumer模型

C++多线程学习笔记004简单的Producer和Consumer模型

引言

Producer为队列中添加“任务”，Consumer自队列中取出并完成“任务”。

实列代码

#include<iostream>
#include<thread>
#include<unistd.h>
#include<mutex>
#include<condition_variable>
#include<queue>

std::queue<int> queue1;
std::condition_variable condtval1;
std::mutex mtx;

void Producer() {
    for(int i = 0; i < 10; i++){
        {   
            std::unique_lock<std::mutex> unlck(mtx);
            queue1.push(i);
            condtval1.notify_one();
            std::cout << "Producer : " << i << std::endl;
        }
        std::this_thread::sleep_for(std::chrono::milliseconds(1000));
    }
}

void Consumer() {
    while(1){
        std::unique_lock<std::mutex> unlck(mtx);
        condtval1.wait(unlck, [] () {return !queue1.empty();});
        int val = queue1.front();
        queue1.pop();
        std::cout << "Consumer : " << val << std::endl;
    }
}

int num {0};



int main(){

    std::thread thread1(Producer);
    std::thread thread2(Consumer);
    thread1.join();
    thread2.join();
    std::cout <<"over" << std::endl;
    return 0;
}
// g++ ./XXX.cpp -o ./XXX -pthread