在Linux系统下生产者消费者,生产者-消费者问题实现 (linux下C语言)
操作系统的一个经典问题是"生产者-消费者"问题, 这涉及同步信号量和互斥信号量的应用, 在这里,我用线程的同步和互斥来实现.
/*
* author 张文
* 2008/06/20
*/
#include #include #include #include #include
#define N 2 // 消费者或者生产者的数目
#define M 10 // 缓冲数目
int in = 0; // 生产者放置产品的位置int out = 0; // 消费者取产品的位置
int buff[M] = {0}; // 缓冲初始化为0, 开始时没有产品
sem_t empty_sem; // 同步信号量, 当满了时阻止生产者放产品sem_t full_sem; // 同步信号量, 当没产品时阻止消费者消费pthread_mutex_t mutex;// 互斥信号量, 一次只有一个线程访问缓冲
int product_id = 0; //生产者idint prochase_id = 0; //消费者id
/* 打印缓冲情况 */
void print()
{
int i;
for(i = 0; i < M; i++)
printf("%d ", buff[i]);
printf("\n");
}
/* 生产者方法 */
void *product()
{
int id = ++product_id;
while(1)
{
// 用sleep的数量可以调节生产和消费的速度,便于观察 sleep(1);
//sleep(1);
sem_wait(&empty_sem);
pthread_mutex_lock(&mutex);
in = in % M;
printf("product%d in %d. like: \t", id, in);
buff[in] = 1;
print();
++in;
pthread_mutex_unlock(&mutex);
sem_post(&full_sem);
}
}
/* 消费者方法 */
void *prochase()
{
int id = ++prochase_id;
while(1)
{
// 用sleep的数量可以调节生产和消费的速度,便于观察
sleep(1);
//sleep(1);
sem_wait(&full_sem);
pthread_mutex_lock(&mutex);
out = out % M;
printf("prochase%d in %d. like: \t", id, out);
buff[out] = 0;
print();
++out;
pthread_mutex_unlock(&mutex);
sem_post(&empty_sem);
}
}
int main()
{
pthread_t id1[N];
pthread_t id2[N];
int i;
int ret[N];
// 初始化同步信号量
int ini1 = sem_init(&empty_sem, 0, M);
int ini2 = sem_init(&full_sem, 0, 0);
if(ini1 && ini2 != 0)
{
printf("sem init failed \n");
exit(1);
}
//初始化互斥信号量int ini3 = pthread_mutex_init(&mutex, NULL);
if(ini3 != 0)
{
printf("mutex init failed \n");
exit(1);
}
// 创建N个生产者线程for(i = 0; i < N; i++)
{
ret[i] = pthread_create(&id1[i], NULL, product, (void *)(&i));
if(ret[i] != 0)
{
printf("product%d creation failed \n", i);
exit(1);
}
}
//创建N个消费者线程for(i = 0; i < N; i++)
{
ret[i] = pthread_create(&id2[i], NULL, prochase, NULL);
if(ret[i] != 0)
{
printf("prochase%d creation failed \n", i);
exit(1);
}
}
//销毁线程for(i = 0; i < N; i++)
{
pthread_join(id1[i],NULL);
pthread_join(id2[i],NULL);
}
exit(0);
}
关于这个程序中的同步和互斥操作,很多网上资料都说必须先同步再互斥,否则会有死锁,我认为这是错的。事实上,生产者中先同步再互斥,而消费者先互斥再同
步,或反之;以及生产者和消费者都先互斥再同步这几种情况都不会死锁,因为它们间并没有交叉关系,就更不可能形成死锁环。之所以先同步,再互斥,是为了更
好的并发性:并发性的瓶颈是互斥区,先同步再互斥,使得互斥区代码更短。
在Linux系统下生产者消费者,生产者-消费者问题实现 (linux下C语言)相关推荐
- linux系统怎样写单片机程序,单片机知识是Linux驱动开发的基础之一以及如何学单片机...
这是arm裸机1期加强版第1课第2.3节课程的wiki文字版. 为什么没前途也要学习单片机? 因为它是个很好的入口. 学习单片机可以让我们抛开复杂的软件结构,先掌握硬件操作,如:看原理图.芯片手册.写 ...
- linux系统能做什么的,Linux系统适合日常使用吗?普通人学Linux能干什么
Linux是多用户多任务系统,多个用户可以同时使用,计算机同时执行多个任务.但对于普通人来说,Linux系统适合日常使用吗?普通人学Linux能干什么?确实是值得深思. Linux是程序员的标配.Li ...
- Linux系统适合日常使用吗?普通人学Linux能干什么
Linux是多用户多任务系统,多个用户可以同时使用,计算机同时执行多个任务.但对于普通人来说,Linux系统适合日常使用吗?普通人学Linux能干什么?确实是值得深思. Linux是程序员的标配.Li ...
- Java File.getPath() File.getAbsolutePath()函数在Windows和Linux系统上存在区别!win正常而linux会报错!
Java File.getPath() File.getAbsolutePath()函数在Windows和Linux系统上存在区别!win正常而linux会报错! 如下图: windows下的源代码和 ...
- u盘安装完linux系统没镜像,U盘刻录kali linux启动盘提示找不到镜像解决方案
U盘刻录14.10镜像出问题的解决方法 从几个月前的14.10 daily 版本就有U盘刻录无法启动的现象,相关bug可参见:https://bugs.launchpad.net/ubunt ... ...
- linux系统如何打开python_手把手教你在Linux系统下使用Python虚拟环境
点击上方" Python爬虫与数据挖掘 ",进行关注 回复"书籍"即可获赠Python从入门到进阶共10本电子书 今 日 鸡 汤 夕阳无限好,只是近黄昏. /1 ...
- linux系统下载不了酷狗,在Ubuntu9.10下安装‘酷狗’成功后,打开‘酷狗’遇到问题?...
chiyb 于 2010-04-26 02:46:20发表: 引用: 谢大宝,指点一下,问题已经解决!! 想改一下版本试试,把'酷狗2010版'卸载,改装'酷狗2008版',就没有以上问题了 baih ...
- linux系统可以玩星际争霸吧,能在Linux系统下运行Windows软件的Wine
Wine,是一款优秀的Linux系统平台下的模拟器软件,用来将Windows系统下的软件在Linux系统下稳定运行,如何配置请看下文 大家看看下面这幅图图1),你一定会惊奇地问:"哇!这不是 ...
- linux系统如何开启网页是否压缩,Windows或Linux下Apache开启GZIP压缩 | kTWO-个人博客...
在搭建web服务器的时候有时因为服务器带宽比较小,而网站内容较多,内容加载较慢,此时建议站长们开启Apache的GZIP压缩功能,注意:开启GZIP之后会增加服务器的压力,不过一般服务器还是可以承受的 ...
- 在linux系统里安装软件,如何使用Homebrew在Linux和Windows上安装软件
导读 长期以来,Homebrew软件一直是Mac用户的便捷工具,但仅适用于Mac用户. 该应用程序增加了Linux风格的软件包管理,使用户可以轻松安装命令行实用程序. 现在,在2.0.0及更高版本中, ...
最新文章
- 关于网页显示乱码问题的一些个人见解(PHP、JSP...)
- STM32F1笔记(十)PWM
- python下设置urllib连接超时
- 项目运行报'vue-cli-service' 不是内部或外部命令,也不是可运行的程序 或批处理文件“
- OpenJudge NOI 1.7 22:紧急措施
- 华为P50系列即将登场:曝线下门店已开始准备样机、物料
- CentOS RPM源镜像源(国内+国外)
- 博客园首页新随笔联系管理订阅订阅随笔- 610 文章- 0 评论- 83 阅读- 144万 Calendar时间获取天,周,月,季度,年度时间段
- 蓝桥杯 ADV-61 算法提高 矩阵乘方
- 《Kotlin项目实战开发》第5章 函数与函数式编程
- 华为ARP代理的三种方式
- position学习终结者(一)
- ajax跨域例子,ajax跨域例子
- arcgis之图斑椭球面积及净面积计算工具
- 中国占三分之一!CBinsights世界最新独角兽排名出炉
- xiuno开发文档_XiunoPHP4.0开发手册 | 雷雨博客
- ADS designguide无法使用解决办法
- linux必应搜索,浏览器UA(四):必应搜索引擎(bing.com)的UserAgent参数
- 关于函数中的return
- golang报错: WaitGroup is reused before previous Wait has returned
热门文章
- 神经网络训练细节之batch normalization
- 嵌入式深度学习运用的思路
- [云炬创业管理笔记]第二章测试5
- 从零开始带你一步一步使用YOLOv3训练自己的数据
- WINDOWS上KAFKA运行环境安装
- mysql和oracle的锁_关于数据库行锁与表锁的认识
- Matlab中配置LibSVM 总结
- ##(两个井号)和#(一个井号)都是什么意思C and C++ 2008-09-23 21:18:27 阅读1106 评论0 字号:大中小 订阅 .
- Asp.Net数据库编程-10条最优方法[翻译]
- Tensorflow2.x.x全卷积神经网络(CNN)