546-C++线程间的同步通信(生产者-消费者模型) 青旅半醒 2022-08-28 15:51 98阅读 0赞 ## 多线程编程两个问题 ## **1.线程间的互斥** 多线程运行时存在竟态条件 =》 临界区代码段 =》 保证其原子操作 =》添加互斥锁mutex 轻量级的无锁实现CAS 在linux中执行 strace ./a.out mutex命令跟踪程序 =>发现底层是用 pthread\_mutex\_t **2.线程间的同步通信** (线程间不通信的话,每个线程受CPU的调度,没有任何执行上的顺序可言,线程1和线程2是根据CPU调度算法来的,两个线程都有可能先运行,是不确定的,线程间的运行顺序是不确定的,所以多线程程序出问题,难以复现,因为谁也不知道当时线程执行的先后顺序,我们一般可以得到每个线程的线程栈信息来分析是否发生死锁的问题之类的。我们要保证线程间的运行顺序) **通信就是**:线程1和线程2一起运行,线程2要做的事情必须先依赖于线程1完成部分的事情,然后告诉线程2这部分东西做好了,线程2就可以继续向下执行了。或者是线程1接下来要做某些操作,这些操作需要线程2把另外一部分事情做完,然后通知一下线程1它做完了,然后线程1才能做这些操作) **生产者,消费者线程模型** ## 生产者-消费者线程模型 ## **生产者生产一个物品,通知消费者消费一个物品;消费者消费完了,消费者再通知生产者继续生产物品** ![在这里插入图片描述][watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBALeael-azveWuhw_size_20_color_FFFFFF_t_70_g_se_x_16] #include <iostream> #include <thread>//多线程的头文件 #include <mutex>//互斥锁的头文件 #include <condition_variable>//条件变量的头文件 #include <queue>//C++ STL所有的容器都不是线程安全 using namespace std; std::mutex mtx;//定义互斥锁,做线程间的互斥操作 std::condition_variable cv;//定义条件变量,做线程间的同步通信操作 //生产者生产一个物品,通知消费者消费一个;消费完了,消费者再通知生产者继续生产物品 class Queue { public: void put(int val)//生产物品 { unique_lock<std::mutex> lck(mtx);//unique_ptr while (!que.empty()) { //que不为空,生产者应该通知消费者去消费,消费者消费完了,生产者再继续生产 //生产者线程进入#1等待状态,并且#2把mtx互斥锁释放掉 cv.wait(lck);//当前线程挂起,处于等待状态,并且释放当前锁 lck.lock() lck.unlock } que.push(val); /* notify_one:通知唤醒另外的一个线程的 notify_all:通知唤醒其它所有线程的 通知其它所有的线程,我生产了一个物品,你们赶紧消费吧 其它线程得到该通知,就会从等待状态 =》 到阻塞状态 =》 但是要获取互斥锁才能继续向下执行 */ cv.notify_all(); cout << "生产者 生产:" << val << "号物品" << endl; } int get()//消费物品 { //lock_guard<std::mutex> guard(mtx);//相当于scoped_ptr unique_lock<std::mutex> lck(mtx);//相当于unique_ptr 更安全 while (que.empty()) { //消费者线程发现que是空的,通知生产者线程先生产物品 //#1 挂起,进入等待状态 #2 把互斥锁mutex释放 cv.wait(lck); }//如果其他线程执行notify了,当前线程就会从等待状态 =》到阻塞状态 =》但是要获取互斥锁才能继续向下执行 int val = que.front(); que.pop(); cv.notify_all();//通知其它线程我消费完了,赶紧生产吧 cout << "消费者 消费:" << val << "号物品" << endl; return val; } private: queue<int> que; }; void producer(Queue *que)//生产者线程 { for (int i = 1; i <= 10; ++i) { que->put(i); std::this_thread::sleep_for(std::chrono::milliseconds(100));//睡眠100毫秒 } } void consumer(Queue *que)//消费者线程 { for (int i = 1; i <= 10; ++i) { que->get(); std::this_thread::sleep_for(std::chrono::milliseconds(100));//睡眠100毫秒 } } int main() { Queue que;//两个线程共享的队列 std::thread t1(producer, &que);//开启生产者线程 std::thread t2(consumer, &que);//开启消费者线程 t1.join(); t2.join(); return 0; } ![在这里插入图片描述][watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBALeael-azveWuhw_size_20_color_FFFFFF_t_70_g_se_x_16 1] ## 再谈mtx和lock\_guard和unique\_lock ## **mtx** ![在这里插入图片描述][watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBALeael-azveWuhw_size_19_color_FFFFFF_t_70_g_se_x_16] mtx.lock(); //不安全,因为代码之间可能由于逻辑走掉了 //代码发生异常了,造成锁没有释放掉,成死锁 mtx.unlock(); **lock\_guard** 利用的是智能指针的概念。 在它的构造函数里面可以主动的获取这把锁lock。 当这个对象出作用域,自动调用析构函数,析构函数中有释放锁的操作unlock。 ![在这里插入图片描述][watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBALeael-azveWuhw_size_20_color_FFFFFF_t_70_g_se_x_16 2] 它把左值引用的拷贝构造函数和赋值函数都删除掉了。 ![在这里插入图片描述][4fe9a269ce464f29b203c09edc413b13.png] ![在这里插入图片描述][watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBALeael-azveWuhw_size_20_color_FFFFFF_t_70_g_se_x_16 3] 不可能用在函数参数传递或者返回过程中,因为要用到拷贝构造函数和赋值函数,只能用在简单的加锁解锁临界区代码段的互斥操作中。 **unique\_lock** ![在这里插入图片描述][d8dcc757f4a04713953d9da7adf83e50.png] 利用的是智能指针的概念。 在它的构造函数里面可以主动的获取这把锁lock。 当这个对象出作用域,自动调用析构函数,析构函数中有释放锁的操作unlock。 ![在这里插入图片描述][watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBALeael-azveWuhw_size_20_color_FFFFFF_t_70_g_se_x_16 4] ![在这里插入图片描述][watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBALeael-azveWuhw_size_20_color_FFFFFF_t_70_g_se_x_16 5] 它把左值引用的拷贝构造函数和赋值函数都删除掉了。 ![在这里插入图片描述][8914d9c828464609abccb9295ee19fe7.png] 但是它提供了右值引用的拷贝构造函数和赋值函数。 所以可以用在函数参数传递或者返回过程中。 ![在这里插入图片描述][watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBALeael-azveWuhw_size_20_color_FFFFFF_t_70_g_se_x_16 6] 它还提供了一对lock和unlock方法。 ![在这里插入图片描述][watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBALeael-azveWuhw_size_20_color_FFFFFF_t_70_g_se_x_16 7] ![在这里插入图片描述][7cd08b28b1524440bc5353c2d779cdc4.png] 当我们在使用条件变量的时候,调用它的wait函数方法,就可以传unique\_lock参数。 std::mutex mtx;//底层是pthread_mutex_t std::condition_variable cv;//底层是pthread_condition_t unique_lock<std::mutex> lck(mtx); cv.wait(lck); //=> #1.使当前线程进入等待状态 #2.lck.unlock可以把mtx给释放掉 /* 通知在cv上等待的线程,条件成立了,起来干活了! 其它在cv上等待的线程,收到通知, 从等待状态 =》到阻塞状态(不能直接运行) =》只有当前线程释放锁了,其他线程才能获取互斥锁了 =》线程继续往下执行 */ cv.notify_all(); [watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBALeael-azveWuhw_size_20_color_FFFFFF_t_70_g_se_x_16]: /images/20220828/a21c99e038274fda8807d948b2c35f45.png [watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBALeael-azveWuhw_size_20_color_FFFFFF_t_70_g_se_x_16 1]: /images/20220828/3bbfa1de0b6840c5987e6e9042e58f9b.png [watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBALeael-azveWuhw_size_19_color_FFFFFF_t_70_g_se_x_16]: /images/20220828/fc6109a855f541fc929149a3b4091e66.png [watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBALeael-azveWuhw_size_20_color_FFFFFF_t_70_g_se_x_16 2]: /images/20220828/7ecd992a3c02442b800d35f26019d9bd.png [4fe9a269ce464f29b203c09edc413b13.png]: /images/20220828/2d526af3fb604a3bba7f01403465118d.png [watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBALeael-azveWuhw_size_20_color_FFFFFF_t_70_g_se_x_16 3]: /images/20220828/0182e05105a9482aa9ed6f135b538858.png [d8dcc757f4a04713953d9da7adf83e50.png]: /images/20220828/417203f106c94ddd85b5006e1e6693d8.png [watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBALeael-azveWuhw_size_20_color_FFFFFF_t_70_g_se_x_16 4]: /images/20220828/84f92c0a17bf42bd862ebca882e10f8b.png [watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBALeael-azveWuhw_size_20_color_FFFFFF_t_70_g_se_x_16 5]: /images/20220828/b44c133b47584d4d9112ace8df08d3a1.png [8914d9c828464609abccb9295ee19fe7.png]: /images/20220828/247312769eb8438386e838ac9a477dd3.png [watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBALeael-azveWuhw_size_20_color_FFFFFF_t_70_g_se_x_16 6]: /images/20220828/b316a64ab5d6478f89e02d5bb2b770d3.png [watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBALeael-azveWuhw_size_20_color_FFFFFF_t_70_g_se_x_16 7]: /images/20220828/898627eaeb2248f38ec23a70d1380a81.png [7cd08b28b1524440bc5353c2d779cdc4.png]: /images/20220828/085d51e1de83470aa2440e23b5373f77.png
相关 Java多线程同步问题:生产者-消费者模型实例 在Java中实现生产者-消费者模型,通常我们会使用`synchronized`关键字、`Lock`接口或者`ReentrantLock`类来实现线程同步。 以下是一个简单的例 我就是我/ 2024年09月10日 22:03/ 0 赞/ 20 阅读
相关 C++ 实现多线程:生产者消费者模型 [C++ std::thread][C_ std_thread] 仓库用于存储生产好的产品,用循环数组来实现 1. 生产者:多个生产者之间互斥,当仓库满时等待,否 分手后的思念是犯贱/ 2023年08月17日 16:47/ 0 赞/ 109 阅读
相关 java多线程:线程间通信——生产者消费者模型 一、背景 && 定义 多线程环境下,只要有并发问题,就要保证数据的安全性,一般指的是通过 synchronized 来进行同步。 另一个问题是,多个线程之间如何协作呢? 亦凉/ 2022年11月29日 05:34/ 0 赞/ 168 阅读
相关 线程通信——多线程同步(生产者消费者例子) 文章目录 前言 一、线程通信概述 二、典型例子 1.生产者和消费者例子 2.通过例子理解与剖析 三、常用API 四 古城微笑少年丶/ 2022年11月02日 00:56/ 0 赞/ 134 阅读
相关 546-C++线程间的同步通信(生产者-消费者模型) 多线程编程两个问题 1.线程间的互斥 多线程运行时存在竟态条件 =》 临界区代码段 =》 保证其原子操作 =》添加互斥锁mutex 轻量级的无锁实现CAS 在l 青旅半醒/ 2022年08月28日 15:51/ 0 赞/ 99 阅读
相关 生产者--消费者模型(线程锁方式) package com.type2; import java.util.concurrent.locks.Condition; import 傷城~/ 2022年08月25日 15:46/ 0 赞/ 127 阅读
相关 生产者--消费者模型(同步方式) package com.th2; import java.util.Hashtable; / 线程池控制类,或 你的名字/ 2022年08月25日 15:46/ 0 赞/ 139 阅读
相关 线程同步:条件变量实现生产者消费者模型 概念: 假设实现一个生产者消费者模型,仓库只能装100万件item,生产者每次生产1件,消费者每次消费1件,为了保持数据的同步,那么生产者每次都需要检查仓库是否满了,消费 今天药忘吃喽~/ 2022年08月19日 05:53/ 0 赞/ 132 阅读
相关 线程间通信-生产者消费者 对于多个生产者和消费者: 1.不要用if ,而要定义while判断标记,使得被唤醒的线程再一次判断标记; 2.需要使用notifyAll唤醒对方线程。因为之用notify, 喜欢ヅ旅行/ 2022年06月16日 02:06/ 0 赞/ 136 阅读
还没有评论,来说两句吧...