William Stallings 《操作系统内核和设计原理》书中Linux下C语言实现读者写者问题(写者优先)代码

本文主要是介绍William Stallings 《操作系统内核和设计原理》书中Linux下C语言实现读者写者问题(写者优先)代码,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

代码能跑,不过实在是观察不出来什么读者优先,或者写者优先。不知道这种优先级的冲突的场景从何而来,也就不知道书上讲得那些情况到底是什么。

特别是在下面代码的writer中,如果引入 sem_wait(&z)的话,writer进程会一直阻塞,从而引起读者也阻塞。去掉后,呈现出读者优先的状况。

#include <stdio.h>
#include <stdlib.h>
#include <unistd.h>
#include <pthread.h>
#include <errno.h>
#include <sys/ipc.h>
#include <semaphore.h>
#include <fcntl.h>void * reader(void *) ;
void *writer (void *) ;sem_t x,y,z,wsem,rsem ;
int readcount=0 ;
int writecount=0 ;main()
{int a=1,b=1;system("clear");sem_init(&wsem,0,1) ;sem_init(&x,0,1) ;sem_init(&rsem,0,1) ;sem_init(&y,0,1) ;sem_init(&z,0,1) ;pthread_t r1,r2,r3;pthread_t w1,w2,w3,w4,w5 ;pthread_create(&r1,NULL,reader,(void *)a);a++;pthread_create(&r2,NULL,reader,(void *)a);a++;pthread_create(&w1,NULL,writer,(void *)b);b++;pthread_create(&w2,NULL,writer,(void *)b);b++;pthread_create(&r3,NULL,reader,(void *)a);a++;pthread_create(&w3,NULL,writer,(void *)b);b++;pthread_create(&w4,NULL,writer,(void *)b);b++;pthread_create(&w5,NULL,writer,(void *)b); //add a readerb++;    printf("main begin join \n");pthread_join(r1,NULL);pthread_join(r2,NULL);pthread_join(w1,NULL);pthread_join(w2,NULL);pthread_join(r3,NULL);pthread_join(w3,NULL) ;pthread_join(w4,NULL);pthread_join(w5,NULL);    printf("main end join\n");sleep(30);printf("main terminated\n");
}void * reader(void * arg)
{int c=(int)arg ;printf("\nreader %d is created",c);//sleep(1);//sem_wait(&z) ;{sem_wait(&rsem) ;{sem_wait(&x) ;readcount++;if( readcount == 1){sem_wait(&wsem) ;} sem_post(&x) ;}sem_post(&rsem) ;}//sem_wait(&z) ;//sleep(1);/*Critcal Section */printf("\nreader %d is reading\n ",c);sleep(10) ;/* critical section completd */sem_wait(&x) ;readcount-- ;if(readcount==0)sem_post(&wsem) ;printf("\nreader %d finished reading,readCount=%d\n",c,readcount);    sem_post(&x) ;
}void * writer(void * arg)
{int c=(int)arg ;printf("\n--------------------writer %d is created",c);sleep(5);sem_wait(&y) ;writecount++;if( writecount == 1){sem_wait(&rsem) ;} sem_post(&y) ;sem_wait(&wsem) ;printf("\n--------------------writer %d is writing\n",c) ;sleep(1);sem_post(&wsem) ;sem_wait(&y) ;writecount--;printf("\n--------------------writer %d finished writing,writecount=%d\n",c,writecount);if( writecount == 0){sem_post(&rsem) ;} sem_post(&y) ;    }

编译方法 :  gcc -o pvrww pv-posix-reader-writer.c -lpthread

这里采用posix的信号量机制。

下面修改代码,能达到写者优先的目的:只要有产生了一个写者线程,那么正在运行的读者进程会在执行结束后,立刻被终止调度,让写者

运行。

#include <stdio.h>先
#include <stdlib.h>
#include <unistd.h>
#include <pthread.h>
#include <errno.h>
#include <sys/ipc.h>
#include <semaphore.h>
#include <fcntl.h>sem_t x,y,z,wsem,rsem ;
int readcount=0 ;
int writecount=0 ;void * reader(void * arg)
{int c= *(int *)arg;printf("\nreader %d is created",c);sem_wait(&z) ;sem_wait(&rsem) ;sem_wait(&x) ;readcount++;printf("\n-------------readcount=%d----- ",readcount);if( readcount == 1){sem_wait(&wsem) ;}sem_post(&x) ;sem_post(&rsem) ;sem_wait(&z) ;/*Critcal Section */printf("\nreader %d is reading\n ",c);sleep(10);    /* critical section completd */sem_wait(&x) ;readcount-- ;if(readcount==0)sem_post(&wsem) ;printf("\nreader %d finished reading,readCount=%d\n",c,readcount);    sem_post(&x) ;pthread_exit(0);
}void * writer(void * arg)
{int c= *(int *)arg;printf("\n--------------------writer %d is created",c);//sleep(5);sem_wait(&y) ;writecount++;printf("\n--------------------writer %d is created,and writecount ==%d",writecount);if( writecount == 1){if( readcount <= 1 ){sem_post(&z) ;sem_post(&rsem) ;}else{sem_wait(&rsem) ;}} sem_post(&y) ;sem_wait(&wsem) ;printf("\n--------------------writer %d is writing\n",c) ;sleep(2);sem_post(&wsem) ;sem_wait(&y) ;writecount--;printf("\n--------------------writer %d finished writing,writecount=%d\n",c,writecount);if( writecount == 0){sem_post(&rsem) ;} sem_post(&y) ;   pthread_exit(0); 
}main()
{int a=1,b=1;sem_init(&wsem,0,1) ;sem_init(&x,0,1) ;sem_init(&rsem,0,1) ;sem_init(&y,0,1) ;sem_init(&z,0,1) ;pthread_t PReader[3];pthread_t PWriter[5];int k =0;for(k = 1; k <= 3; k++)        //创建顾客线程{pthread_create(&(PReader[k-1]),NULL,(void *)reader,&k);srand(time(0));sleep(rand() % 2 + 1);    //1到3的随机数}for(k = 1; k <= 5; k++)        //创建顾客线程{pthread_create(&(PWriter[k-1]),NULL,(void *)writer,&k);srand(time(0));sleep(rand() % 2 + 1);    //1到3的随机数}for(k = 0; k < 3; k++){pthread_join(PReader[k],NULL);      }sleep(30);for(k = 1; k <= 5; k++){pthread_kill(PWriter[k-1],0); }//sleep(30);printf("\nmain terminated\n");
}



这篇关于William Stallings 《操作系统内核和设计原理》书中Linux下C语言实现读者写者问题(写者优先)代码的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



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

相关文章

不懂推荐算法也能设计推荐系统

本文以商业化应用推荐为例,告诉我们不懂推荐算法的产品,也能从产品侧出发, 设计出一款不错的推荐系统。 相信很多新手产品,看到算法二字,多是懵圈的。 什么排序算法、最短路径等都是相对传统的算法(注:传统是指科班出身的产品都会接触过)。但对于推荐算法,多数产品对着网上搜到的资源,都会无从下手。特别当某些推荐算法 和 “AI”扯上关系后,更是加大了理解的难度。 但,不了解推荐算法,就无法做推荐系

linux-基础知识3

打包和压缩 zip 安装zip软件包 yum -y install zip unzip 压缩打包命令: zip -q -r -d -u 压缩包文件名 目录和文件名列表 -q:不显示命令执行过程-r:递归处理,打包各级子目录和文件-u:把文件增加/替换到压缩包中-d:从压缩包中删除指定的文件 解压:unzip 压缩包名 打包文件 把压缩包从服务器下载到本地 把压缩包上传到服务器(zip

好题——hdu2522(小数问题:求1/n的第一个循环节)

好喜欢这题,第一次做小数问题,一开始真心没思路,然后参考了网上的一些资料。 知识点***********************************无限不循环小数即无理数,不能写作两整数之比*****************************(一开始没想到,小学没学好) 此题1/n肯定是一个有限循环小数,了解这些后就能做此题了。 按照除法的机制,用一个函数表示出来就可以了,代码如下

hdu1043(八数码问题,广搜 + hash(实现状态压缩) )

利用康拓展开将一个排列映射成一个自然数,然后就变成了普通的广搜题。 #include<iostream>#include<algorithm>#include<string>#include<stack>#include<queue>#include<map>#include<stdio.h>#include<stdlib.h>#include<ctype.h>#inclu

hdu1180(广搜+优先队列)

此题要求最少到达目标点T的最短时间,所以我选择了广度优先搜索,并且要用到优先队列。 另外此题注意点较多,比如说可以在某个点停留,我wa了好多两次,就是因为忽略了这一点,然后参考了大神的思想,然后经过反复修改才AC的 这是我的代码 #include<iostream>#include<algorithm>#include<string>#include<stack>#include<

深入探索协同过滤:从原理到推荐模块案例

文章目录 前言一、协同过滤1. 基于用户的协同过滤(UserCF)2. 基于物品的协同过滤(ItemCF)3. 相似度计算方法 二、相似度计算方法1. 欧氏距离2. 皮尔逊相关系数3. 杰卡德相似系数4. 余弦相似度 三、推荐模块案例1.基于文章的协同过滤推荐功能2.基于用户的协同过滤推荐功能 前言     在信息过载的时代,推荐系统成为连接用户与内容的桥梁。本文聚焦于

【C++】_list常用方法解析及模拟实现

相信自己的力量,只要对自己始终保持信心,尽自己最大努力去完成任何事,就算事情最终结果是失败了,努力了也不留遗憾。💓💓💓 目录   ✨说在前面 🍋知识点一:什么是list? •🌰1.list的定义 •🌰2.list的基本特性 •🌰3.常用接口介绍 🍋知识点二:list常用接口 •🌰1.默认成员函数 🔥构造函数(⭐) 🔥析构函数 •🌰2.list对象

【Prometheus】PromQL向量匹配实现不同标签的向量数据进行运算

✨✨ 欢迎大家来到景天科技苑✨✨ 🎈🎈 养成好习惯,先赞后看哦~🎈🎈 🏆 作者简介:景天科技苑 🏆《头衔》:大厂架构师,华为云开发者社区专家博主,阿里云开发者社区专家博主,CSDN全栈领域优质创作者,掘金优秀博主,51CTO博客专家等。 🏆《博客》:Python全栈,前后端开发,小程序开发,人工智能,js逆向,App逆向,网络系统安全,数据分析,Django,fastapi

hdu4407(容斥原理)

题意:给一串数字1,2,......n,两个操作:1、修改第k个数字,2、查询区间[l,r]中与n互质的数之和。 解题思路:咱一看,像线段树,但是如果用线段树做,那么每个区间一定要记录所有的素因子,这样会超内存。然后我就做不来了。后来看了题解,原来是用容斥原理来做的。还记得这道题目吗?求区间[1,r]中与p互质的数的个数,如果不会的话就先去做那题吧。现在这题是求区间[l,r]中与n互质的数的和