三个同步与互斥问题之生产者与消费者

2024-09-07 12:08

本文主要是介绍三个同步与互斥问题之生产者与消费者,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

#include<stdio.h>
#include<pthread.h>
pthread_mutex_t  mutex;
#define Max 10


pthread_cond_t pro;
pthread_cond_t con;


int buffer=0;//全局变量----一开始为0,只有生产者可以执行


void deal_produce(void *arg)
{//消费---
int i;
for(i=1;i<=Max;i++)
{//
pthread_mutex_lock(&mutex);
while(buffer!=0)  pthread_cond_wait(&pro,&mutex);//锁住生产者,在有产品的时候
printf("producer produce item :%d\n",i);
buffer=i;
pthread_cond_signal(&con);//通知消费者
pthread_mutex_unlock(&mutex);

}
pthread_exit(NULL);


}


void deal_consume(void *arg)
{//生产
int i;
for(i=1;i<=Max;i++)
{//加锁,消费的时候不准生产

pthread_mutex_lock(&mutex);
while(buffer==0) pthread_cond_wait(&con,&mutex);
printf("consumer consume item :%d\n",i);
buffer=0;//!?buffer--?
if(buffer==0) pthread_cond_signal(&pro);//没货待产
pthread_mutex_unlock(&mutex);
}
pthread_exit(NULL);


}
int main()
{
    pthread_t consumer,producer;


    pthread_mutex_init(&mutex,0);
//0 :NULL  
//API :int pthread_mutex_init(pthread_mutex_t *mutex, const pthread_mutexattr_t *mutexattr)


    pthread_cond_init(&pro,0);
    pthread_cond_init(&con,0);


   pthread_create(&producer,NULL,&deal_produce,NULL); 
   pthread_create(&consumer,NULL,&deal_consume,NULL);    
   
    pthread_join(consumer);
    pthread_join(producer);

   pthread_cond_destroy(&pro);
   pthread_cond_destroy(&con);


    exit(0);
}

这篇关于三个同步与互斥问题之生产者与消费者的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/1145019

相关文章

线上Java OOM问题定位与解决方案超详细解析

《线上JavaOOM问题定位与解决方案超详细解析》OOM是JVM抛出的错误,表示内存分配失败,:本文主要介绍线上JavaOOM问题定位与解决方案的相关资料,文中通过代码介绍的非常详细,需要的朋... 目录一、OOM问题核心认知1.1 OOM定义与技术定位1.2 OOM常见类型及技术特征二、OOM问题定位工具

Vue3绑定props默认值问题

《Vue3绑定props默认值问题》使用Vue3的defineProps配合TypeScript的interface定义props类型,并通过withDefaults设置默认值,使组件能安全访问传入的... 目录前言步骤步骤1:使用 defineProps 定义 Props步骤2:设置默认值总结前言使用T

Python与MySQL实现数据库实时同步的详细步骤

《Python与MySQL实现数据库实时同步的详细步骤》在日常开发中,数据同步是一项常见的需求,本篇文章将使用Python和MySQL来实现数据库实时同步,我们将围绕数据变更捕获、数据处理和数据写入这... 目录前言摘要概述:数据同步方案1. 基本思路2. mysql Binlog 简介实现步骤与代码示例1

Web服务器-Nginx-高并发问题

《Web服务器-Nginx-高并发问题》Nginx通过事件驱动、I/O多路复用和异步非阻塞技术高效处理高并发,结合动静分离和限流策略,提升性能与稳定性... 目录前言一、架构1. 原生多进程架构2. 事件驱动模型3. IO多路复用4. 异步非阻塞 I/O5. Nginx高并发配置实战二、动静分离1. 职责2

解决升级JDK报错:module java.base does not“opens java.lang.reflect“to unnamed module问题

《解决升级JDK报错:modulejava.basedoesnot“opensjava.lang.reflect“tounnamedmodule问题》SpringBoot启动错误源于Jav... 目录问题描述原因分析解决方案总结问题描述启动sprintboot时报以下错误原因分析编程异js常是由Ja

Java Kafka消费者实现过程

《JavaKafka消费者实现过程》Kafka消费者通过KafkaConsumer类实现,核心机制包括偏移量管理、消费者组协调、批量拉取消息及多线程处理,手动提交offset确保数据可靠性,自动提交... 目录基础KafkaConsumer类分析关键代码与核心算法2.1 订阅与分区分配2.2 拉取消息2.3

MySQL 表空却 ibd 文件过大的问题及解决方法

《MySQL表空却ibd文件过大的问题及解决方法》本文给大家介绍MySQL表空却ibd文件过大的问题及解决方法,本文给大家介绍的非常详细,对大家的学习或工作具有一定的参考借鉴价值,需要的朋友参考... 目录一、问题背景:表空却 “吃满” 磁盘的怪事二、问题复现:一步步编程还原异常场景1. 准备测试源表与数据

解决Nginx启动报错Job for nginx.service failed because the control process exited with error code问题

《解决Nginx启动报错Jobfornginx.servicefailedbecausethecontrolprocessexitedwitherrorcode问题》Nginx启... 目录一、报错如下二、解决原因三、解决方式总结一、报错如下Job for nginx.service failed bec

SysMain服务可以关吗? 解决SysMain服务导致的高CPU使用率问题

《SysMain服务可以关吗?解决SysMain服务导致的高CPU使用率问题》SysMain服务是超级预读取,该服务会记录您打开应用程序的模式,并预先将它们加载到内存中以节省时间,但它可能占用大量... 在使用电脑的过程中,CPU使用率居高不下是许多用户都遇到过的问题,其中名为SysMain的服务往往是罪魁

MySQ中出现幻读问题的解决过程

《MySQ中出现幻读问题的解决过程》文章解析MySQLInnoDB通过MVCC与间隙锁机制在可重复读隔离级别下解决幻读,确保事务一致性,同时指出性能影响及乐观锁等替代方案,帮助开发者优化数据库应用... 目录一、幻读的准确定义与核心特征幻读 vs 不可重复读二、mysql隔离级别深度解析各隔离级别的实现差异