linux使用线程实现生产者消费者问题,Linux平台下线程同步,实现“生产者消费者问题”...
(1)线程同步,实现“生产者消费者问题”
要求:缓冲区大小为20,生产者每次放一个产品,消费者每次取走一个产品;生产者和消费者至少2个。
(2)代码如下:
#include
#include
#include
#include
void *producter_f (void *arg);/*生产者*/
void *consumer_f (void *arg);/*消费者*/
int buffer_has_item=0;/*缓冲区计数值*/
pthread_mutex_t mutex;/*互斥区*/
//pthread_cond_t mqlock= PTHREAD_COND_INITIALIZER;
int running =1 ;/*线程运行控制*/
int main (void)
{
pthread_t consumer_t;/*消费者线程参数*/
pthread_t producter_t;/*生产者线程参数*/
pthread_mutex_init (&mutex,NULL);/*初始化互斥*/
pthread_create(&producter_t, NULL,(void*)producter_f, NULL );/*建立生产者线程*/
pthread_create (&consumer_t, NULL, (void *)consumer_f, NULL);/*建立消费者线程*/
//usleep(1);/*等待,线程创建完毕*/
//running =0;/*设置线程退出值*/
pthread_join(consumer_t,NULL);/*等待消费者线程退出*/
pthread_join(producter_t,NULL);/*等待生产者线程退出*/
pthread_mutex_destroy(&mutex);/*销毁互斥*/
return 0;
}
void *producter_f (void *arg)/*生产者线程程序*/
{
while(running)/*没有设置退出值*/
{
pthread_mutex_lock (&mutex);/*进入互斥区*/
if(buffer_has_item > 20) /*缓冲区满则不生产*/
{
pthread_mutex_unlock(&mutex);
usleep(1);
}
buffer_has_item++;/*增加计数值*/
printf("生产,总数量:%d\n",buffer_has_item); /*打印信息*/
pthread_mutex_unlock(&mutex);/*离开互斥区*/
}
}
void *consumer_f(void *arg)/*消费者线程程序*/
{
while(running)/*没有设置退出值*/
{
pthread_mutex_lock(&mutex);/*进入互斥区*/
buffer_has_item--;/*减小计数值*/
if(buffer_has_item < 0) /*缓冲区空则不消费*/
{
pthread_mutex_unlock(&mutex);
usleep(1);
}
printf("消费,总数量:%d\n",buffer_has_item);/*打印信息*/
pthread_mutex_unlock(&mutex);/*离开互斥区*/
}
}
(2)第二种,加入同步机制
#include
#include
#include
#include
#include
#define N 2 // 消费者或者生产者的数目
#define M 20 // 缓冲数目
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; //生产者id
int 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; //当生产者进入的时候 执行计数加1
while (1)
{
// 用sleep的数量可以调节生产和消费的速度,便于观察
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);
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
{
pthread_join(id1[i],NULL);
pthread_join(id2[i],NULL);
}
exit(0);
}
运行结果:
linux使用线程实现生产者消费者问题,Linux平台下线程同步,实现“生产者消费者问题”...相关推荐
- linux qt 获取u盘名称,QT windows平台下获取U盘 QComboBox显示U盘盘符
在windows平台下获取U盘信息,可以调用windows API函数比较方便.本来想用qt 来写的,网上关于这方面的代码比较多,但按照提示的步骤来写的就是无法编译,我也不知道为什么.如果有知道的朋友 ...
- 【EventBus】事件通信框架 ( 发送事件 | 判断发布线程是否是主线程 | 子线程切换主线程 | 主线程切换子线程 )
文章目录 前言 一.根据不同的线程模式进行不同的线程切换操作 二.完整代码示例 前言 发布线程发布事件之后 , 消息中心需要转发这些事件 , 并执行相应的订阅方法 ; 在转发的过程中 , 需要针对订阅 ...
- linux使用线程实现生产者消费者问题,Linux下生产者与消费者的线程实现
代码见<现代操作系统> 第3版. 为了显示效果,添加了printf()函数来显示运行效果 #include #include #define MAX 20 pthread_mutex_t ...
- Linux下实现多线程的生产者消费者问题
Linux下实现多线程的生产者消费者问题 一.原理的理解 生产者-消费者问题是一个经典的线程同步问题,该问题最早由Dijkstra提出,用以演示他提出的信号量机制.在同一个线程地址空间内执行的两个线程 ...
- linux 生产者消费者 多进程,Linux多线程,生产者消费者算法和条件变量的使用
接着上一篇博文,原来双线程,现在为了实现 暂停/继续 功能,又加了一个线程.第三线程使用条件信号量,当用户按下S键,第三线程将检测到,并且将ifpause置为1,然后输出线程将在if语句成立后被条件信 ...
- 用三个线程实现生产者消费者模型,其中一个线程作为生产者,二个线程作为消费者,生产者随机生产一个时间戳或者字符串,消费者消费这个时间戳,并不能重复消费,并将其打印出来
题目要求: 用三个线程实现生产者消费者模型,其中一个线程作为生产者,二个线程作为消费者,生产者随机生产一个时间戳或者字符串,消费者消费这个时间戳,并不能重复消费,并将其打印出来.(这是一道百度面试的算 ...
- Linux C编程--线程操作1--线程概述和简单的线程操作
关于linux线程 在许多经典的操作系统教科书中, 总是把进程定义为程序的执行实例, 它并不执行什么, 只是维护应用程序所需的各种资源. 而线程则是真正的执行实体. 为了让进程完成一定的工作, 进程 ...
- 线程同步 生产者消费者 java_Java线程同步:生产者-消费者 模型(代码示例)
public class ThreadSyn { public static void main(String[] args) { new ThreadSyn(); } public ThreadSy ...
- std string与线程安全_详解linux系统中断线程的那些事
很多情况下,使用信号来终止一个长时间运行的线程是合理的.这种线程的存在,可能是因为工作线程所在的线程池被销毁,或是用户显式的取消了这个任务,亦或其他各种原因.不管是什么原因,原理都一样:需要使用信号来 ...
最新文章
- maven构建SSM工程[应用]1
- Android属性动画 TypeEvaluator
- 带你封装一个上传图片组件(ant design+react)
- hdoj 1015 Safecracker
- 华为软件java笔试_华为软件笔试题4.10
- java memcached incr_Memcached incr/decr 命令
- ffmpeg音频播放代码示例-avcodec_decode_audio4
- SQL-24 获取所有非manager员工当前的薪水情况,给出dept_no、emp_no以及salary ,当前表示to_date='9999-01-01'...
- 七、MySQL中的字符集 - 系统的撸一遍MySQL
- PyTorch——nn.Conv2d和其中的padding策略,Caffe、Tensorflow的padding策略
- 路由器OSPF配置2
- 项目开发中dev、test和prod是什么意思
- C/C++文件指针偏移
- 计算机大三学生怎么找实习工作?学了计算机很迷茫怎么办?
- 探讨PHP实现站内搜索引擎的具体方法
- LSTM长短期记忆网络对车辆尾气排放进行预测
- 丧心病狂的前端冷知识
- Windows 无法使用内置管理员账户打开IE
- android 按钮带图标 阴影_Android Material Design系列之FloatingActionButton和Snackbar
- centos 虚拟机输入大小写混乱问题
热门文章
- 在Scrapy中使用Chrome中的cookie
- activiti框架 数据库设计说明书
- react 组件的属性
- Redis源码研究—基础知识
- React Native学习笔记-1:JSC profiler is not supported.(转载)
- 关于Eclipse平台的使用和开发第一个SWT程序
- 来来来,个人blog第一弹——WordPress的Linux运行环境
- spring集成xmemcached
- Hadoop:The Definitive Guid 总结 Chapter 7 MapReduce的类型与格式
- CF1173A 【Nauuo and Votes】题解