进程同步实验,用C++模拟几个进程的执行过程,并使用信号量解决生产者-消费者问题,需要代码注释,100行左右的代码

时间: 2023-09-30 13:10:37 浏览: 87
以下是一个基于信号量的生产者-消费者问题的C++代码,注释已经添加在代码中。 ```c++ #include <iostream> #include <pthread.h> #include <semaphore.h> #define BUFFER_SIZE 10 // 缓冲区大小 #define PRODUCER_NUM 3 // 生产者数量 #define CONSUMER_NUM 2 // 消费者数量 int buffer[BUFFER_SIZE]; // 缓冲区 int in = 0; // 缓冲区写入位置 int out = 0; // 缓冲区读取位置 sem_t empty; // 缓冲区空槽数量 sem_t full; // 缓冲区满槽数量 sem_t lock; // 互斥锁 void *producer(void *arg) { int id = *(int *)arg; int item = 0; while (true) { // 产生新产品 item = rand() % 1000; std::cout << "Producer " << id << " produced item " << item << std::endl; // 生产者等待空槽位 sem_wait(&empty); // 获取互斥锁 sem_wait(&lock); // 将产品添加到缓冲区中 buffer[in] = item; in = (in + 1) % BUFFER_SIZE; // 释放互斥锁 sem_post(&lock); // 通知消费者可以消费了 sem_post(&full); } } void *consumer(void *arg) { int id = *(int *)arg; int item = 0; while (true) { // 消费者等待满槽位 sem_wait(&full); // 获取互斥锁 sem_wait(&lock); // 从缓冲区中取出产品 item = buffer[out]; out = (out + 1) % BUFFER_SIZE; // 释放互斥锁 sem_post(&lock); // 通知生产者可以继续生产了 sem_post(&empty); // 消费产品 std::cout << "Consumer " << id << " consumed item " << item << std::endl; } } int main() { // 初始化信号量 sem_init(&empty, 0, BUFFER_SIZE); sem_init(&full, 0, 0); sem_init(&lock, 0, 1); // 创建生产者线程 pthread_t producers[PRODUCER_NUM]; int producer_ids[PRODUCER_NUM]; for (int i = 0; i < PRODUCER_NUM; i++) { producer_ids[i] = i + 1; pthread_create(&producers[i], NULL, producer, &producer_ids[i]); } // 创建消费者线程 pthread_t consumers[CONSUMER_NUM]; int consumer_ids[CONSUMER_NUM]; for (int i = 0; i < CONSUMER_NUM; i++) { consumer_ids[i] = i + 1; pthread_create(&consumers[i], NULL, consumer, &consumer_ids[i]); } // 等待所有线程结束 for (int i = 0; i < PRODUCER_NUM; i++) { pthread_join(producers[i], NULL); } for (int i = 0; i < CONSUMER_NUM; i++) { pthread_join(consumers[i], NULL); } // 销毁信号量 sem_destroy(&empty); sem_destroy(&full); sem_destroy(&lock); return 0; } ``` 以上代码中,生产者和消费者通过信号量进行进程同步,保证了缓冲区的正确访问顺序。其中,`sem_wait()` 函数会阻塞当前线程,直到信号量的值大于0,并将信号量的值减1;`sem_post()` 函数会将信号量的值加1,并唤醒正在等待该信号量的线程。`sem_init()` 函数用于初始化信号量,`sem_destroy()` 函数用于销毁信号量。

相关推荐

最新推荐

recommend-type

生产者消费者的c++代码实现

计算机操作系统经典的生产者消费者问题c++高级语言的实现。编程入门必备。
recommend-type

C++获取特定进程CPU使用率的实现代码

写一个小程序在后台记录每个进程的CPU使用情况,揪出锁屏后占用CPU的进程,于是自己写了一个C++类CPUusage,方便地监视不同进程的CPU占用情况。本人编程还只是个新手,如有问题请多多指教
recommend-type

vscode使用官方C/C++插件无法进行代码格式化问题

官方的C/C++插件是支持使用.clang-format配置文件进行自定义风格代码格式化的,无需另外安装clang-format插件。 但是使用clang-format -style=llvm -dump-config &gt; .clang-format导出的默认配置文件进行格式化的时候...
recommend-type

c++获取进程信息列表和进程所调用的dll列表

主要介绍了c++获取进程信息列表和进程所调用的dll列表,大家参考使用吧
recommend-type

C++ boost::asio编程-同步TCP详解及实例代码

主要介绍了C++ boost::asio编程-同步TCP详解及实例代码的相关资料,需要的朋友可以参考下
recommend-type

zigbee-cluster-library-specification

最新的zigbee-cluster-library-specification说明文档。
recommend-type

管理建模和仿真的文件

管理Boualem Benatallah引用此版本:布阿利姆·贝纳塔拉。管理建模和仿真。约瑟夫-傅立叶大学-格勒诺布尔第一大学,1996年。法语。NNT:电话:00345357HAL ID:电话:00345357https://theses.hal.science/tel-003453572008年12月9日提交HAL是一个多学科的开放存取档案馆,用于存放和传播科学研究论文,无论它们是否被公开。论文可以来自法国或国外的教学和研究机构,也可以来自公共或私人研究中心。L’archive ouverte pluridisciplinaire
recommend-type

实现实时数据湖架构:Kafka与Hive集成

![实现实时数据湖架构:Kafka与Hive集成](https://img-blog.csdnimg.cn/img_convert/10eb2e6972b3b6086286fc64c0b3ee41.jpeg) # 1. 实时数据湖架构概述** 实时数据湖是一种现代数据管理架构,它允许企业以低延迟的方式收集、存储和处理大量数据。与传统数据仓库不同,实时数据湖不依赖于预先定义的模式,而是采用灵活的架构,可以处理各种数据类型和格式。这种架构为企业提供了以下优势: - **实时洞察:**实时数据湖允许企业访问最新的数据,从而做出更明智的决策。 - **数据民主化:**实时数据湖使各种利益相关者都可
recommend-type

用 Python 画一个可以动的爱心

好的,我可以帮助您使用Python来绘制一个动态的爱心。您可以使用turtle库来实现。以下是实现代码: ```python import turtle import math # 设置画布和画笔 canvas = turtle.Screen() canvas.bgcolor("black") pencil = turtle.Turtle() pencil.speed(0) pencil.color("red", "pink") pencil.pensize(3) # 定义爱心函数 def draw_love(heart_size, x_offset=0, y_offset=0):
recommend-type

JSBSim Reference Manual

JSBSim参考手册,其中包含JSBSim简介,JSBSim配置文件xml的编写语法,编程手册以及一些应用实例等。其中有部分内容还没有写完,估计有生之年很难看到完整版了,但是内容还是很有参考价值的。