news 2026/1/2 14:58:49

操作系统课程设计：1-多线程同步实验

作者头像

张小明

前端开发工程师

1.2k 24
文章封面图
操作系统课程设计：1-多线程同步实验

1.实验目的

1.掌握线程的概念及创建方法

2.掌握线程互斥锁及条件变量同步机制

3.掌握POSIX信号量机制

4.掌握生产者消费者原理

5.设计程序，两种方法实现多线程生产者消费者同步问题

2.实验截图及结果分析

（1）实验截图

（2）实验结果分析

本次实验通过使用条件变量和互斥锁以及Posix信号量两种方式实现生产者消费者同步问题，实验结果展示了程序在多线程环境下数据的正确生产与消费，体现了线程同步机制的有效性。

①条件变量和互斥锁实现方式

数据生产与消费顺序：从实验截图的输出结果来看，生产者1和生产者2交替向缓冲区写入数据，且写入位置和值符合预期。消费者1和消费者2也能按顺序从缓冲区读取数据，每次读取的数据值与生产者写入的值一致，这表明在条件变量和互斥锁的同步机制下，生产者和消费者线程之间的协作正常，数据的读写顺序正确，没有出现数据竞争或混乱的情况。

缓冲区满与空的处理：当缓冲区满时，生产者线程会根据条件判断进入阻塞等待状态，直到消费者从缓冲区取出数据，通过条件变量notfull唤醒生产者线程继续写入数据；当缓冲区空时，消费者线程会通过条件变量notempty等待，直到生产者写入数据后被唤醒读取数据。这说明条件变量和互斥锁有效地控制了缓冲区的状态，避免了缓冲区溢出和下溢的问题，保证了数据的安全性和完整性。

线程执行频率：在生产者1和生产者2以及消费者1和消费者2的代码中，均设置了每次操作后休眠1秒的机制，这使得线程的执行频率得到了有效控制，输出结果清晰有序，便于观察和分析线程的执行过程。

② Posix信号量实现方式

奇偶数据生产控制：生产者1按照预期只生产奇数，生产者2只生产偶数，这表明通过对n的奇偶判断以及信号量的同步机制，成功实现了对生产者生产数据的约束，保证了数据生产的正确性和特定性。

信号量同步效果：Posix信号量mutex、empty和full在控制线程同步方面发挥了重要作用。empty信号量控制了生产者向缓冲区写入数据的时机，只有当empty信号量的值大于0时，生产者才能写入数据，从而避免了缓冲区满时的写入操作；full信号量控制了消费者从缓冲区读取数据的时机，当full信号量的值大于0时，消费者才能读取数据，防止了缓冲区空时的读取操作；mutex信号量则保证了对缓冲区的访问是线程安全的，避免了多个线程同时访问缓冲区导致的数据错误。

线程协作稳定性：与条件变量和互斥锁实现方式类似，通过设置线程每次操作后的休眠时间，使得线程的执行过程清晰可见。在整个实验过程中，生产者和消费者线程能够稳定协作，没有出现线程死锁或数据错误的情况，证明了Posix信号量在解决生产者消费者同步问题上的可靠性。

③ 两种实现方式的对比

条件变量和互斥锁以及Posix信号量都能有效地解决生产者消费者同步问题，但在实现细节和适用场景上存在一定差异。条件变量和互斥锁的组合使用，通过对条件的判断和等待机制，更侧重于线程之间的条件同步；而Posix信号量则通过对信号量值的操作来控制线程的执行，更侧重于资源的计数和控制。在实际应用中，可根据具体需求和场景选择合适的同步机制。

3.实验程序

（1）采用条件变量和互斥锁解决生产者消费者问题

prodcons.c

#include <stdio.h> #include <pthread.h> #include <unistd.h> // 为了使用 sleep 函数 #define BUFSIZE 8 int n = 1, m = 1; struct prodcons { int buffer[BUFSIZE]; pthread_mutex_t lock; // 互斥LOCK int readpos, writepos; pthread_cond_t notempty; // 缓冲区非空条件判断 pthread_cond_t notfull; // 缓冲区未满条件判断 }; void init(struct prodcons *b) { pthread_mutex_init(&b->lock, NULL); pthread_cond_init(&b->notempty, NULL); pthread_cond_init(&b->notfull, NULL); b->readpos = 0; b->writepos = 0; } struct prodcons buffer; void *producer1(void *data) { while (1) { if (buffer.writepos % 2 == 0) { pthread_mutex_lock(&(buffer.lock)); // 等待缓冲区未满 if ((buffer.writepos + 1) % BUFSIZE == buffer.readpos) { // 缓冲区满,生产者将被挂起,直至重新被唤醒 pthread_cond_wait(&(buffer.notfull), &(buffer.lock)); } // 写数据,并移动指针 printf(" "); printf("producer1 start putting: put position is %d, put value is %d\n", buffer.writepos, n); buffer.buffer[buffer.writepos] = n; buffer.writepos++; if (buffer.writepos >= BUFSIZE) buffer.writepos = 0; // 设置缓冲区非空的条件变量 pthread_cond_signal(&(buffer.notempty)); pthread_mutex_unlock(&(buffer.lock)); n++; } sleep(1); // 生产者1每次操作后休眠1秒 } } void *producer2(void *data) { while (1) { if (buffer.writepos % 2 != 0) { pthread_mutex_lock(&(buffer.lock)); // 等待缓冲区未满 if ((buffer.writepos + 1) % BUFSIZE == buffer.readpos) { // 缓冲区满,生产者将被挂起,直至重新被唤醒 pthread_cond_wait(&(buffer.notfull), &(buffer.lock)); } // 写数据,并移动指针 printf(" "); printf("producer2 start putting: put position is %d, put value is %d\n", buffer.writepos, n); buffer.buffer[buffer.writepos] = n; buffer.writepos++; if (buffer.writepos >= BUFSIZE) buffer.writepos = 0; // 设置缓冲区非空的条件变量 pthread_cond_signal(&(buffer.notempty)); pthread_mutex_unlock(&(buffer.lock)); n++; } sleep(1); // 生产者2每次操作后休眠1秒 } } void *consumer1(void *data) { int d; while (1) { pthread_mutex_lock(&(buffer.lock)); if (buffer.writepos == buffer.readpos) { // 等待缓冲区非空 pthread_cond_wait(&(buffer.notempty), &(buffer.lock)); } // 读数据,移动读指针 d = buffer.buffer[buffer.readpos]; printf("first consumer: get position is %d, get value is %d\n", buffer.readpos, d); buffer.readpos++; if (buffer.readpos >= BUFSIZE) buffer.readpos = 0; // 设置缓冲区未满的条件变量 pthread_cond_signal(&(buffer.notfull)); pthread_mutex_unlock(&(buffer.lock)); sleep(1); // 消费者1每次操作后休眠1秒 } return NULL; } void *consumer2(void *data) { int d; while (1) { pthread_mutex_lock(&(buffer.lock)); if (buffer.writepos == buffer.readpos) { // 等待缓冲区非空 pthread_cond_wait(&(buffer.notempty), &(buffer.lock)); } // 读数据,移动读指针 d = buffer.buffer[buffer.readpos]; printf("second consumer: get position is %d, get value is %d\n", buffer.readpos, d); buffer.readpos++; if (buffer.readpos >= BUFSIZE) buffer.readpos = 0; // 设置缓冲区未满的条件变量 pthread_cond_signal(&(buffer.notfull)); pthread_mutex_unlock(&(buffer.lock)); sleep(1); // 消费者2每次操作后休眠1秒 } return NULL; } int main(void) { pthread_t th_a, th_b, th_c, th_d; void *retval; init(&buffer); pthread_create(&th_a, NULL, producer1, 0); pthread_create(&th_b, NULL, producer2, 0); pthread_create(&th_c, NULL, consumer1, 0); pthread_create(&th_d, NULL, consumer2, 0); pthread_join(th_a, &retval); pthread_join(th_b, &retval); pthread_join(th_c, &retval); pthread_join(th_d, &retval); return 0; }

（2）使用Posix信号量解决生产者消费者问题

prodcons-semwait.c

#include <stdio.h> #include <stdlib.h> #include <time.h> #include <sys/types.h> #include <pthread.h> #include <semaphore.h> #include <string.h> #include <unistd.h> #define BUFSIZE 8 sem_t mutex, empty, full; int n = 1, m = 1; struct prodcons { int buffer[BUFSIZE]; int readpos, writepos; }; void init(struct prodcons *b) { b->readpos = 0; b->writepos = 0; } struct prodcons buffer; // producer1 只生产奇数 void *producer1(void *arg) { while (1) { if (n % 2 != 0) { sem_wait(&empty); sem_wait(&mutex); printf("producer1 is putting: put pos is %d, put %d\n", buffer.writepos, n); buffer.buffer[buffer.writepos] = n; buffer.writepos++; if (buffer.writepos >= BUFSIZE) { buffer.writepos = 0; } n++; sem_post(&mutex); sem_post(&full); } sleep(1); // 控制生产速度 } return NULL; } // producer2 只生产偶数 void *producer2(void *arg) { while (1) { if (n % 2 == 0) { sem_wait(&empty); sem_wait(&mutex); printf("producer2 is putting: put pos is %d, put %d\n", buffer.writepos, n); buffer.buffer[buffer.writepos] = n; buffer.writepos++; if (buffer.writepos >= BUFSIZE) { buffer.writepos = 0; } n++; sem_post(&mutex); sem_post(&full); } sleep(1); // 控制生产速度 } return NULL; } void *consumer1(void *arg) { int data; while (1) { sem_wait(&full); sem_wait(&mutex); data = buffer.buffer[buffer.readpos]; printf("consumer1 is getting: get pos is %d, get %d\n", buffer.readpos, data); buffer.readpos++; if (buffer.readpos >= BUFSIZE) { buffer.readpos = 0; } sleep(1); // 控制消费速度 sem_post(&mutex); sem_post(&empty); } return NULL; } void *consumer2(void *arg) { int data; while (1) { sem_wait(&full); sem_wait(&mutex); data = buffer.buffer[buffer.readpos]; printf("consumer2 is getting: get pos is %d, get %d\n", buffer.readpos, data); buffer.readpos++; if (buffer.readpos >= BUFSIZE) { buffer.readpos = 0; } sleep(1); // 控制消费速度 sem_post(&mutex); sem_post(&empty); } return NULL; } int main(void) { pthread_t th_a, th_b, th_c, th_d; void *retval; init(&buffer); sem_init(&mutex, 0, 1); sem_init(&empty, 0, 8); sem_init(&full, 0, 0); pthread_create(&th_a, NULL, producer1, NULL); pthread_create(&th_b, NULL, producer2, NULL); pthread_create(&th_c, NULL, consumer1, NULL); pthread_create(&th_d, NULL, consumer2, NULL); pthread_join(th_a, &retval); pthread_join(th_b, &retval); pthread_join(th_c, &retval); pthread_join(th_d, &retval); sem_destroy(&mutex); sem_destroy(&empty); sem_destroy(&full); return 0; }
版权声明: 本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若内容造成侵权/违法违规/事实不符，请联系邮箱：809451989@qq.com进行投诉反馈，一经查实，立即删除！
网站建设 2025/12/31 14:17:24

大厂Java面试故事：微服务、分布式缓存与AI场景全链路技术深挖

大厂Java面试故事&#xff1a;微服务、分布式缓存与AI场景全链路技术深挖 故事引入 谢飞机&#xff0c;江湖人称“水货程序员”&#xff0c;这天终于鼓起勇气&#xff0c;踏进了某互联网大厂的面试间。面试官气场强大&#xff0c;谢飞机幽默应对。面试内容围绕支付金融、分布式…

作者头像 李华
网站建设 2025/12/31 22:09:19

EmotiVoice支持RESTful API吗？集成方式详解

EmotiVoice支持RESTful API吗&#xff1f;集成方式详解 在智能语音应用日益普及的今天&#xff0c;开发者不再满足于“能说话”的TTS系统&#xff0c;而是追求更自然、更具情感表达力的声音。尤其是在虚拟主播、有声读物、游戏NPC等场景中&#xff0c;用户期待的是带有情绪起伏…

作者头像 李华
网站建设 2026/1/1 12:43:26

Mac效率革命：用Pearcleaner告别繁琐的Homebrew命令行操作

还在为反复敲击brew install、brew upgrade而烦恼&#xff1f;还在为权限问题、缓存清理而头疼&#xff1f;作为Mac开发者或重度命令行用户&#xff0c;你值得拥有更优雅的解决方案。 【免费下载链接】Pearcleaner Open-source mac app cleaner 项目地址: https://gitcode.co…

作者头像 李华
网站建设 2025/12/23 9:34:03

Windows安卓子系统终极指南：MagiskOnWSALocal完整安装教程

Windows安卓子系统终极指南&#xff1a;MagiskOnWSALocal完整安装教程 【免费下载链接】MagiskOnWSALocal Integrate Magisk root and Google Apps into WSA (Windows Subsystem for Android) 项目地址: https://gitcode.com/gh_mirrors/ma/MagiskOnWSALocal 还在为Wind…

作者头像 李华
网站建设 2025/12/23 15:57:10

从GitHub到生产环境：EmotiVoice项目落地全流程拆解

从GitHub到生产环境&#xff1a;EmotiVoice项目落地全流程拆解 在智能语音产品日益普及的今天&#xff0c;用户早已不再满足于“能说话”的机器。他们期待的是有温度、有情绪、能表达个性的声音——就像真人一样。然而&#xff0c;传统TTS系统往往受限于音色单一、情感匮乏和部…

作者头像 李华
网站建设 2026/1/1 4:46:46

终极解锁：如何用Edge插件快速获得Netflix 4K影院级画质体验

终极解锁&#xff1a;如何用Edge插件快速获得Netflix 4K影院级画质体验 【免费下载链接】netflix-4K-DDplus MicrosoftEdge(Chromium core) extension to play Netflix in 4K&#xff08;Restricted&#xff09;and DDplus audio 项目地址: https://gitcode.com/gh_mirrors/n…

作者头像 李华