C共享内存整数未更新

如何解决C共享内存整数未更新

我正在用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，您正在创建单独的进程。因此，您应该将此参数设置为非零。