c语言实现生产者/消费者进程(线程)的同步与互斥。在该程序中创建4个进程(或线程)模拟生产者和消费者,实现进程(线程)的同步与互斥。

时间: 2024-05-09 17:15:50 浏览: 144
以下是一个基于C语言实现生产者/消费者进程(线程)的同步与互斥的示例代码: ```c #include <stdio.h> #include <stdlib.h> #include <pthread.h> #include <semaphore.h> #define BUFFER_SIZE 10 // 缓冲区大小 #define PRODUCER_NUM 2 // 生产者线程数 #define CONSUMER_NUM 2 // 消费者线程数 sem_t mutex, empty, full; // 三个信号量 int buffer[BUFFER_SIZE]; // 缓冲区数组 int in = 0, out = 0; // 生产者和消费者的缓冲区指针 void *producer(void *arg) { int id = *(int *)arg; while (1) { int item = rand() % 100; // 随机生成一个生产的物品 sem_wait(&empty); // 等待缓冲区非满 sem_wait(&mutex); // 进入临界区 buffer[in] = item; // 将物品放入缓冲区 printf("Producer %d produced item %d\n", id, item); in = (in + 1) % BUFFER_SIZE; // 生产者缓冲区指针移动 sem_post(&mutex); // 退出临界区 sem_post(&full); // 增加缓冲区元素个数 sleep(1); // 等待一段时间再生产下一个物品 } } void *consumer(void *arg) { int id = *(int *)arg; while (1) { sem_wait(&full); // 等待缓冲区非空 sem_wait(&mutex); // 进入临界区 int item = buffer[out]; // 从缓冲区取出物品 printf("Consumer %d consumed item %d\n", id, item); out = (out + 1) % BUFFER_SIZE; // 消费者缓冲区指针移动 sem_post(&mutex); // 退出临界区 sem_post(&empty); // 减少缓冲区元素个数 sleep(2); // 等待一段时间再消费下一个物品 } } int main() { srand(time(NULL)); sem_init(&mutex, 0, 1); // 初始化互斥信号量 sem_init(&empty, 0, BUFFER_SIZE); // 初始化空信号量 sem_init(&full, 0, 0); // 初始化满信号量 pthread_t producer_threads[PRODUCER_NUM], consumer_threads[CONSUMER_NUM]; int producer_ids[PRODUCER_NUM], consumer_ids[CONSUMER_NUM]; for (int i = 0; i < PRODUCER_NUM; ++i) { producer_ids[i] = i + 1; pthread_create(&producer_threads[i], NULL, producer, &producer_ids[i]); } for (int i = 0; i < CONSUMER_NUM; ++i) { consumer_ids[i] = i + 1; pthread_create(&consumer_threads[i], NULL, consumer, &consumer_ids[i]); } for (int i = 0; i < PRODUCER_NUM; ++i) { pthread_join(producer_threads[i], NULL); } for (int i = 0; i < CONSUMER_NUM; ++i) { pthread_join(consumer_threads[i], NULL); } sem_destroy(&mutex); sem_destroy(&empty); sem_destroy(&full); return 0; } ``` 该程序中,使用了三个信号量:`mutex`表示互斥信号量,`empty`表示空信号量,`full`表示满信号量。生产者和消费者进程(线程)都需要在临界区内对缓冲区进行操作,因此需要使用互斥信号量来保证互斥。生产者线程在往缓冲区中放入物品时,需要判断缓冲区是否已满,若已满则需要等待,因此需要使用空信号量;而消费者线程在从缓冲区中取出物品时,需要判断缓冲区是否为空,若为空则需要等待,因此需要使用满信号量。 在 `main` 函数中,首先使用 `sem_init` 函数对三个信号量进行初始化。然后创建多个生产者和消费者线程,并使用 `pthread_create` 函数启动线程。最后使用 `pthread_join` 函数等待所有线程结束,并使用 `sem_destroy` 函数销毁三个信号量。 在 `producer` 和 `consumer` 函数中,使用 `sem_wait` 函数和 `sem_post` 函数来对信号量进行操作,实现进程(线程)的同步与互斥。其中,`sem_wait` 函数会阻塞当前进程(线程),直到对应信号量的值不为0;而 `sem_post` 函数会增加对应信号量的值。 在 `producer` 函数中,首先随机生成一个物品,然后使用 `sem_wait` 函数等待缓冲区非满。当缓冲区非满时,使用 `sem_wait` 函数进入临界区,将物品放入缓冲区,并输出生产者编号和物品编号。最后使用 `sem_post` 函数退出临界区,并使用 `sem_post` 函数增加缓冲区元素个数。 在 `consumer` 函数中,首先使用 `sem_wait` 函数等待缓冲区非空。当缓冲区非空时,使用 `sem_wait` 函数进入临界区,从缓冲区取出物品,并输出消费者编号和物品编号。最后使用 `sem_post` 函数退出临界区,并使用 `sem_post` 函数减少缓冲区元素个数。 注意,本示例代码仅供参考,实际应用中需要根据具体情况进行相应的修改和调整。
阅读全文

相关推荐

最新推荐

recommend-type

OS大作业生产者消费者同步问题的实现

在主函数中,分别创建了生产者线程`t_write`和消费者线程`t_read`,并在最后通过`pthread_join`等待它们完成。 8. **程序流程**:生产者线程不断生成字符并尝试放入缓冲区,若缓冲区满则等待;消费者线程则不断尝试...
recommend-type

企业信息化管理系统-NodeJS-Express-EJS-Bootstrap-MySQL-前后端分离-Web应用开发-企业员工加班点餐系统-基于RESTfulAPI-数据库驱动-响.zip

企业信息化管理系统_NodeJS_Express_EJS_Bootstrap_MySQL_前后端分离_Web应用开发_企业员工加班点餐系统_基于RESTfulAPI_数据库驱动_响.zip上传一个【C语言】VIP资源
recommend-type

会计中都有哪些必须熟练掌握的Excel公式【会计实务经验之谈】(1)(1).doc

会计中都有哪些必须熟练掌握的Excel公式【会计实务经验之谈】(1)(1).doc
recommend-type

基于ASP.NET技术的高校学生综合素质网上测评系统架构(1).docx

基于ASP.NET技术的高校学生综合素质网上测评系统架构(1).docx
recommend-type

单片机实验开发板程序编写指南

单片机实验程序的知识点可以从单片机的概念、开发板的作用、实验的目的以及具体程序编写与调试方面进行详细阐述。 首先,单片机(Single-Chip Microcomputer),又称微控制器,是将中央处理单元(CPU)、随机存取存储器(RAM)、只读存储器(ROM)、输入输出接口等主要计算机功能部件集成在一片芯片上的微小型计算机。它具备独立处理特定任务的能力,广泛应用于嵌入式系统中。单片机由于其成本低廉、体积小、功耗低、控制简单等特点,被广泛应用于家用电器、办公自动化、汽车电子、工业控制等众多领域。 接着,开发板(Development Board)是为了方便开发者使用单片机而设计的一种实验平台,通常集成了单片机、电源管理模块、外围接口电路、调试接口、编程接口等。开发板的主要作用是提供一个简洁的硬件环境,让开发者可以更容易地进行实验、测试和程序开发。在使用开发板进行单片机实验时,可以通过编程器将用户编写的程序烧录到单片机中,然后进行实际操作和测试。 实验的目的通常是为了验证某些特定的功能或者算法。在实验中,开发者可以使用单片机开发板来实现对输入信号的检测、处理和输出控制。例如,可以编写程序使单片机控制LED灯的亮灭,或者读取按键输入并根据按键的不同进行不同的控制。实验程序可以是一个简单的循环处理,也可以是复杂的算法实现,如数据通信、中断处理、定时器使用等。 在编写单片机实验程序时,首先需要了解所使用的单片机的指令集和硬件资源。以常用的8051单片机为例,需要熟悉其寄存器配置、特殊功能寄存器(SFR)的使用以及I/O口操作等。编写程序时,通常会使用C语言或者汇编语言。C语言因其可读性好、编写效率高而更受欢迎。开发者可以使用Keil uVision、IAR Embedded Workbench等集成开发环境(IDE)来编写、编译和调试代码。 在程序调试阶段,可以通过开发板上的调试接口,如JTAG、ISP等,将编译好的程序下载到单片机中。调试过程通常包括设置断点、单步执行、查看寄存器和内存内容等操作。通过调试可以发现并修正程序中的逻辑错误或硬件交互问题。 另外,为了保证程序的可靠性和稳定性,实验程序设计时还应考虑异常处理、资源管理以及功耗优化等因素。编写高效的单片机程序不仅仅是让程序按预期运行,还要考虑到程序运行的效率、资源消耗以及对异常情况的应对。 总之,基于开发板的单片机实验程序开发涉及到硬件理解、软件编程、程序调试等多个环节。开发者需要将理论知识与实际操作相结合,通过不断的学习和实践,掌握单片机编程和应用开发的关键技能。这不仅需要对单片机的基础知识有深入的了解,还需要对开发板的功能和特性有充分的认识,从而能够设计出高效、稳定和实用的单片机应用系统。
recommend-type

【性能测试基准】:为RK3588选择合适的NVMe性能测试工具指南

# 1. NVMe性能测试基础 ## 1.1 NVMe协议简介 NVMe,全称为Non-Volatile Memory Express,是专为固态驱动器设计的逻辑设备接口规范。与传统的SATA接口相比,NVMe通过使用PCI Express(PCIe)总线,大大提高了存储设备的数据吞吐量和IOPS(每秒输入输出操作次数),特别适合于高速的固态存储设备。
recommend-type

ubuntu 检查下载源

<think>我们正在讨论Ubuntu系统中检查和配置下载源(软件源)的方法。用户的需求很明确:如何检查当前配置的下载源,以及如何修改它们。根据引用[1]和[2]中的信息,我们知道在Ubuntu中,软件源配置存储在`/etc/apt/sources.list`文件中以及`/etc/apt/sources.list.d/`目录下的额外文件中。修改源通常包括备份当前配置、编辑源列表文件、更新软件包列表等步骤。步骤分解:1.检查当前下载源:可以通过查看`sources.list`文件和`sources.list.d/`目录中的文件内容来实现。2.修改下载源:包括备份、编辑源列表(替换为新的镜像源地址
recommend-type

办公软件:下载使用指南与资源包

标题中提到的“offices办公软件”,指的是Office套件,这是一系列办公应用程序的集合,通常包括文字处理软件(如Microsoft Word)、电子表格软件(如Microsoft Excel)、演示文稿制作软件(如Microsoft PowerPoint),以及邮件管理软件等。该软件包旨在帮助用户提高工作效率,完成文档撰写、数据分析、演示制作等多种办公任务。 描述部分非常简单,提到“一个很好公办软件你一定很爱他快来下载吧加强团结”,表达了对软件的高度评价和期待用户下载使用,以促进工作中的团结协作。不过,这段描述中可能存在错别字或排版问题,正确的表达可能是“一款非常好的办公软件,你一定很爱它,快来下载吧,加强团结”。 标签部分为“dddd”,这显然不是一个有效的描述或分类标签,它可能是由于输入错误或者故意设置的占位符。 压缩包子文件的文件名称列表中包含了以下文件: - keygen.exe:这是一个序列号生成器的可执行文件,通常用于生成软件的注册码或激活码,使得用户能够在不支付授权费用的情况下使用某些付费软件。然而,这通常是违反软件许可协议的行为,也可能涉及到法律风险。 - 说明_Readme.html:这是一个HTML格式的说明文件,通常会包含该软件的安装指南、使用方法、版本信息、已知问题、版权声明和致谢等内容。阅读这个文件可以帮助用户正确安装和使用软件。 - OfficeSuite 4_50.sis:这是一个适用于Symbian操作系统的安装包文件,SIS是Symbian Install File的缩写。从文件名可以看出,这是一个名为“OfficeSuite”的软件的第50个版本,版本号为4.0。Symbian曾是智能手机操作系统之一,通常用于诺基亚等品牌的设备上,但随着智能手机市场的变化,现在已很少见,市场上主流的智能手机操作系统已转向Android和iOS。 - resource:这个名称很模糊,没有文件扩展名,因此无法确定具体是什么类型的资源。它可能是一个包含字体、图像或其他资源文件的文件夹,这些资源文件用于支持Office套件在不同设备或操作系统上的运行。 在使用这些文件时,特别是涉及到keygen.exe这类软件时,用户应谨慎行事。应避免使用未经授权的软件,不仅因为其可能违反法律,还可能对计算机系统造成安全风险。在下载和安装任何软件时,应确保来源的可靠性,并从官方渠道获取正版授权。此外,对于已经过时或不再受支持的软件,比如针对Symbian系统的OfficeSuite,用户可能需要寻找其他替代方案来满足当前的办公需求。
recommend-type

【固态硬盘寿命延长】:RK3588平台NVMe维护技巧大公开

# 1. 固态硬盘寿命延长的基础知识 ## 1.1 固态硬盘的基本概念 固态硬盘(SSD)是现代计算设备中不可或缺的存储设备之一。与传统的机械硬盘(HDD)相比,SSD拥有更快的读写速度、更小的体积和更低的功耗。但是,SSD也有其生命周期限制,主要受限于NAND闪存的写入次数。 ## 1.2 SSD的写入次数和寿命 每块SSD中的NAND闪存单元都有有限的写入次数。这意味着,随着时间的推移,SSD的
recommend-type

DSNPx是什么

<think>我们正在处理一个关于保险精算领域的问题,具体是定期寿险净保费计算。用户询问的是"DSNPx"的定义或含义,特别是在计算机领域的含义。根据提供的代码和上下文,我们可以分析如下:1.在代码中,变量名`NPxM`和`NPxF`分别代表男性(M)和女性(F)的净保费(NetPremium)。而前缀"DS"可能是"定期寿险"(DingQiShouXian)的缩写,因为函数名为`DingQi`,代表定期寿险。2.因此,`DSNPxM`和`DSNPxF`分别表示定期寿险(DS)的净保费(NP)对于男性(x年龄,M)和女性(x年龄,F)。3.在精算学中,净保费是指不考虑费用和利润的纯风险保费,根