生产者-消费者线程模型学习

生产者消费者模型基本框架：

也就是一个线程扮演生产者往资源池放入数据，另一个线程扮演消费者从资源池中取出数据（当资源池为空时不能取数据），因为资源池是共享的，所以需要互斥量保证当一个线程操作资源池时，另一个线程不能操作资源池，也就是生产和和消费者不能同时操作资源池

涉及技术

unique_lock+mutex+condition_variable

代码实现：

#include<iostream>
#include<thread>
#include<mutex>
#include<deque>
#include<condition_variable>
using std::cout;
using std::endl;
std::mutex m;
std::deque<int> q;
std::condition_variable con;
void producer() {
    
	int count = 10;
	while (count > 0) {
    
	    std::unique_lock<std::mutex> locker(m);
	    q.push_front(count);
	    cout << "producer producer a value "<<count<<" !" << endl;
	    locker.unlock();
	    //1.unique_lock有unlock功能，lock_guard妹有
	    //2.由于notify_one不需要被互斥保护，所以可以提前unlock(尽量使用细粒度锁)
	    con.notify_one();
	    std::this_thread::sleep_for(std::chrono::milliseconds(500));
	    --count;
	}
}
void consumer() {
    
	int data = 0;
	while (data != 1) {
    
	    std::unique_lock<std::mutex> locker(m);
	    con.wait(locker, []() {
    return !q.empty();});
	    //1.休眠直到deque内有东西才会被producer唤醒
	    //2.locker睡眠的时候会调用unlock()，直到被唤醒又会继续持有锁保证后面的操作是安全的
	    //3.传入lambda函数是为了防止系统造成的伪唤醒，这是我们不想看到的
	    data = q.back();
	    q.pop_back();
	    locker.unlock();
	    cout << "cosumer got value "<<data<< " from producer!" << endl;
	}
}
int main() {
    
	std::thread thread1(producer);
	std::thread thread2(consumer);
	thread1.join();
	thread2.join();
	return 0;
}