生产者消费者模型
时间:2022-06-10
本文章向大家介绍生产者消费者模型,主要内容包括其使用实例、应用技巧、基本知识点总结和需要注意事项,具有一定的参考价值,需要的朋友可以参考一下。
生产者消费者模型主要有以下函数和对象
//线程锁对象
pthread_mutex_t mutex;
//用于初始化pthread_mutex_t锁对象
pthread_mutex_init(&mutex, NULL);
//用于销毁pthread_mutex_t锁对象
pthread_mutex_destroy(&mutex)
//线程条件对象
pthread_cond_t cond;
//用于初始化pthread_cond_t线程条件对象
pthread_cond_init(&cond, NULL);
//用于销毁pthread_cond_t线程条件对象
pthread_cond_destroy(&cond);
//用于上锁mutex,本线程上锁后的其他变量是不能
被别的线程操作
pthread_mutex_lock(&mutex);
//用于解锁mutex,解锁后的其他变量可以被其他线程操作
pthread_mutex_unlock(&mutex);
//用于发出条件信号
pthread_cond_signal(&cond);
//用于线程阻塞等待,这个函数会解锁,直到pthread_cond_signal发出条件信号后才执行退出线程阻塞执行后面的操作
才执行退出线程阻塞执行后面的操作
pthread_cond_wait(&cond, &mutex);
示例代码如下:
#include "pthread.h"
#include "queue"
#include "unistd.h"
pthread_t produc;
pthread_t custom;
pthread_mutex_t mutex;
pthread_cond_t cond;
std::queue<int> queue;
void *producCallback(void *data)
{
while (1)
{
pthread_mutex_lock(&mutex);
queue.push(1);
LOGD("生产者生产一个产品,通知消费者消费, 产品数量为 %d", queue.size());
pthread_cond_signal(&cond);
pthread_mutex_unlock(&mutex);
sleep(5);
}
pthread_exit(&produc);
}
void *customCallback(void *data)
{
while (1)
{
pthread_mutex_lock(&mutex);
if(queue.size() > 0)
{
queue.pop();
LOGD("消费者消费产品,产品数量还剩余 %d ", queue.size());
} else{
LOGD("没有产品可以消费, 等待中...");
pthread_cond_wait(&cond, &mutex);
}
pthread_mutex_unlock(&mutex);
usleep(500 * 1000);
}
pthread_exit(&custom);
pthread_mutex_destroy(&mutex);
pthread_cond_destroy(&cond);
}
extern "C"
JNIEXPORT void JNICALL
Java_com_zzw_jnithread_ThreadDemo_mutexThread(JNIEnv *env, jobject instance) {
for(int i = 0; i < 10; i++)
{
queue.push(1);
}
pthread_mutex_init(&mutex, NULL);
pthread_cond_init(&cond, NULL);
pthread_create(&produc, NULL, producCallback, NULL);
pthread_create(&custom, NULL, customCallback, NULL);
}
- 五年换4高管,6000员工裁95%剩300人,王健林为何抛弃万达网科?
- Android Permission中英对照
- 你知道人脸识别技术是如何实现的吗?
- WordPress REST API 定制化输出
- ASP.NET MVC的Action Filter
- Android LayoutInflater详解
- 在Android中实现service动态更新UI界面
- VUE 入门基础(5)
- Android的UI设计与后台线程交互
- 更强悍的Silverlight: WCF RIA Services
- Java究竟该怎么学?文末有彩蛋!
- python-IDLE清屏和标记行数,其他推荐
- 从0到1:PostCSS 插件开发最佳实践
- VUE 入门基础(4)
- JavaScript 教程
- JavaScript 编辑工具
- JavaScript 与HTML
- JavaScript 与Java
- JavaScript 数据结构
- JavaScript 基本数据类型
- JavaScript 特殊数据类型
- JavaScript 运算符
- JavaScript typeof 运算符
- JavaScript 表达式
- JavaScript 类型转换
- JavaScript 基本语法
- JavaScript 注释
- Javascript 基本处理流程
- Javascript 选择结构
- Javascript if 语句
- Javascript if 语句的嵌套
- Javascript switch 语句
- Javascript 循环结构
- Javascript 循环结构实例
- Javascript 跳转语句
- Javascript 控制语句总结
- Javascript 函数介绍
- Javascript 函数的定义
- Javascript 函数调用
- Javascript 几种特殊的函数
- JavaScript 内置函数简介
- Javascript eval() 函数
- Javascript isFinite() 函数
- Javascript isNaN() 函数
- parseInt() 与 parseFloat()
- escape() 与 unescape()
- Javascript 字符串介绍
- Javascript length属性
- javascript 字符串函数
- Javascript 日期对象简介
- Javascript 日期对象用途
- Date 对象属性和方法
- Javascript 数组是什么
- Javascript 创建数组
- Javascript 数组赋值与取值
- Javascript 数组属性和方法
- python如何进入交互模式
- PHP静态方法和静态属性及常量属性的区别与介绍
- 详解PHP变量传值赋值和引用赋值变量销毁
- Keras 利用sklearn的ROC-AUC建立评价函数详解
- PHP如何防止XSS攻击与XSS攻击原理的讲解
- 如何验证python安装成功
- python三引号如何输入
- Python定义一个函数的方法
- keras 模型参数,模型保存,中间结果输出操作
- python判断是空的实例分享
- keras绘制acc和loss曲线图实例
- 基于Python实现2种反转链表方法代码实例
- Python smtp邮件发送模块用法教程
- Python3基于print打印带颜色字符串
- Python StringIO及BytesIO包使用方法解析