问题描述
我正在用C实现读写器问题。正如您所看到的，我分叉了2次，每次生成一个读写器都需要一定的等待时间。我也使用两个信号量满足了线程安全性。首先是{r}来保护rcount，然后是mutex来防止互斥。问题是，尽管我将其用作共享内存，但计数器的值却没有改变。
代码：
writeblock错误终端：
#include <stdio.h>
#include <semaphore.h>
#include <sys/ipc.h>
#include <sys/shm.h>
sem_t mutex,writeblock;
int data = 0,rcount = 0,shmid;
void reader()
{
sem_wait(&mutex);
rcount = rcount + 1;
if(rcount==1)
sem_wait(&writeblock);
int *counter=shmat(shmid,NULL,0);
printf("im a reader and counter is %d \n\n",*counter);
shmdt(counter);
sem_post(&mutex);
sleep(1);
sem_wait(&mutex);
rcount = rcount - 1;
if(rcount==0)
sem_post(&writeblock);
sem_post(&mutex);
}
void writer()
{
sem_wait(&writeblock);
int status=0;
int *counter=shmat(shmid,0);
*counter++;
printf("im a writer and I incremented the counter and after that the counter is %d \n\n",*counter);
shmdt(counter);
sleep(1);
sem_post(&writeblock);
}
int main()
{
int i,b;
sem_init(&mutex,1);
sem_init(&writeblock,1);
shmid = shmget(IPC_PRIVATE,sizeof(int),IPC_CREAT | 0666);
if (shmid <0)
printf("shmget err");
if(fork()==0)
{
for (i=0;i<2;i++)
{
if(fork()==0)
{
sleep(i);
writer();
}
}
}
else
{
for (i=0;i<2;i++)
{
if(fork()==0)
{
sleep(i*2);
reader();
}
}
}
}
解决方法
*counter++递增计数器，而不递增计数器指向的内容。 (*counter)++递增计数器指向的内容。
如另一个答案中所述，表达式*counter++是错误的。由于rules of operator precedence，它必须为(*counter)++。
但是，即使修复了该错误，您的程序仍无法按预期运行，原因有以下几种：
在您的问题中，您通过以下语句描述了程序的预期行为：
如您所见，我分叉了2次，每次都会产生需要一定等待的读取器或写入器。
您的陈述不正确。实际上，您分叉了7次，这意味着您有8个进程。这些过程中的3个将调用writer函数，而3个将调用reader函数。
在第一个for循环中，在该循环的第一次迭代中分叉的子进程将按预期调用writer函数，但是此后，它将不会脱离该循环。相反，它将执行循环的第二次迭代。这意味着您有两个进程执行循环的第二次迭代。
由于这可能不是故意的，因此建议您将第一个for循环更改为以下内容：
for (i=0;i<2;i++)
{
if(fork()==0)
{
sleep(i);
writer();
break; //breaks out of "for" loop
}
}
您的第二个for循环（else块内的循环）具有相同的问题。
在修复了两个循环之后，您现在只需要分叉5次，因此总共有6个进程。这可能就是您想要的。第一个过程创建两个写程序，还创建一个过程，创建两个读程序。
但是，程序的另一个问题是每个进程都有自己的rcount变量副本。因此，必须对该变量执行与使用counter变量（将使用共享内存）相同的操作。
此外，您正在调用参数sem_init设置为零的函数pshared。根据{{3}}，这仅应在同一进程的线程之间共享信号量时执行。但是，使用fork，您正在创建单独的进程。因此，您应该将此参数设置为非零。