gpt4 book ai didi

C - 读取器/写入器(并发): Forking & Semaphores Output

转载 作者:行者123 更新时间:2023-11-30 17:43:42 26 4
gpt4 key购买 nike

我正在编写一个关于信号量和 fork 的读者/作者问题的实现(这是必需的,而不是不幸的 pthreads)。

这是读者的偏好,基本上是用户指定读者/作者的数量,并且程序 fork 出每个读者/作者所请求的数量。编写者选择一个随机数,将其写入关键部分,并将其报告给控制台。读者只需报告当前的数字即可。

我使用信号量来管理它,出于某种原因,一旦一个进程获得关键部分,它就会迭代所有预定数量的循环,然后才允许下一个进程访问它。我觉得这可能与我在 main 中的 fork()-ing 循环有关,尽管我不确定。

编辑:抱歉,如果我的问题不完全清楚;下面的输出显示了每个进程(读取器 1、写入器 1 等),每个进程连续两次访问临界区(如果我将迭代增加到 10,则访问次数将是 10 倍),这不是我想要的。它应该有一个更随机的输出(每个进程访问它一次然后将其传递)。我不明白为什么每个进程都能够像现在这样阻止访问。

下面是代码:

#include <stdlib.h>
#include <stdio.h>
#include <sys/mman.h>
#include "asm/unistd.h"

#include <semaphore.h>

#define ITERATION 2

int *readCount, *crit_sec;
sem_t wrt, mutex, *s1, *s2;

void writer (int numWriter) {
sem_wait(&wrt);
*crit_sec = rand() % 100 + 1;
printf("Writer %d - Wrote: %d\n", numWriter, *crit_sec);
sem_post(&wrt);

return;
}

void reader (int numReader) {
sem_wait(&mutex);
*readCount++;
if (*readCount == 1) sem_wait(&wrt);
sem_post(&mutex);
printf("Reader %d - Read: %d\n", numReader, *crit_sec);
sem_wait(&mutex);
*readCount--;
if (*readCount==0) sem_post(&wrt);
sem_post(&mutex);

return;
}

int main (int argv, char **argc) {
int numRead, numWrite;
void *ptr1 = mmap(NULL, 2*sizeof(int), PROT_READ | PROT_WRITE, MAP_SHARED | MAP_ANONYMOUS, 0, 0);
void *ptr2 = mmap(NULL, 2*sizeof(sem_t), PROT_READ | PROT_WRITE, MAP_SHARED | MAP_ANONYMOUS, 0, 0);
crit_sec=ptr1, readCount=ptr1+1;
*crit_sec=0, *readCount=0;

s1=ptr2, s2=ptr2+1;
*s1=mutex, *s2=wrt;
sem_init(&mutex,1,1);
sem_init(&wrt,1,1);

if (argv !=3) {
printf("Incorrect usage - must use: ./ReadersWriters [# readers] [# writers]\n");
return 0;
}

if (sscanf (argc[1], "%i", &numRead)!=1|| sscanf (argc[2], "%i", &numWrite)!=1) {
printf("Incorrect usage - must use: ./ReadersWriters [# readers] [# writers]\n");
return 0;
}

int rcnt = 0;
while (rcnt++ < numRead) {
if (fork()==0) {
int i=0;
for(;i<ITERATION;i++) reader(rcnt);
return;
}
}

int wcnt = 0;
while (wcnt++ < numWrite) {
if (fork()==0) {
int j=0;
for (;j<ITERATION;j++) writer(wcnt);
return;
}
}

return 0;
}

这是一个示例输出(尽管处理顺序可能不同):

Reader 1 - Read: 0
Reader 1 - Read: 0
Writer 1 - Wrote: 84
Writer 1 - Wrote: 87
Reader 2 - Read: 87
Reader 2 - Read: 87
Writer 2 - Wrote: 84
Writer 2 - Wrote: 87

感谢您的帮助!

最佳答案

Sorry, what I mean is that I don't want each process to control the critical section multiple iterations in a row without handing it off.

如果一个线程调用 e,调度程序没有义务切换到另一个线程。 G。 sem_post(),尤其是不使用标准调度策略 SCHED_OTHER(请参阅 man sched_setscheduler)。也就是说,使用 #define ITERATION 5 我有时会得到 e。例如:

Reader 1 - Read: 0
Reader 2 - Read: 0
Reader 1 - Read: 0
Reader 1 - Read: 0
Reader 1 - Read: 0
Reader 2 - Read: 0
Reader 1 - Read: 0
Reader 2 - Read: 0
Reader 2 - Read: 84
Reader 2 - Read: 84
Writer 1 - Wrote: 84
Writer 1 - Wrote: 87
Writer 2 - Wrote: 84
Writer 2 - Wrote: 87
Writer 2 - Wrote: 78
Writer 1 - Wrote: 78
Writer 2 - Wrote: 16
Writer 1 - Wrote: 16
Writer 2 - Wrote: 94
Writer 1 - Wrote: 94

关于C - 读取器/写入器(并发): Forking & Semaphores Output,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/20183564/

26 4 0
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com