当前位置: 首页 > 知识库问答 >
问题:

信号量和共享内存

师承弼
2023-03-14

代码是:

#include <sys/ioctl.h>
#include <sys/types.h>
#include <sys/wait.h>
#include <sys/ipc.h>
#include <sys/sem.h>
#include <stdio.h>
#include <unistd.h>

#include <time.h>
#include <stdlib.h>

const key_t sem_key = (key_t)0x12345678;
const key_t shm_key = (key_t)0x12339678;

struct shared_data{
  int random_num;
};

union semun{
  int val; //setval value
};

int sem_wait(int semafor_id){
  struct sembuf sb;
  sb.sem_num = 0;
  sb.sem_op = -1;
  sb.sem_flg = SEM_UNDO;

  return semop(semafor_id,&sb,1);
}

int sem_signal(int semafor_id){
  struct sembuf sb;
  sb.sem_num = 0;
  sb.sem_op = 1;
  sb.sem_flg = SEM_UNDO;

  return semop(semafor_id,&sb,1);
}

int main(int argc,char* argv[]){

  int status;

  srand(time(NULL));
  //Create shared memory
  int memory_id = shmget(shm_key,sizeof(struct shared_data),0600|IPC_CREAT|IPC_EXCL);
  if(memory_id < 0){
    printf("Shared memory creating failed\n");
    return 1;
  }

  //Create semafor
  int semafor_id = semget(sem_key,10, 0600|IPC_CREAT|IPC_EXCL);
  if(semafor_id < 0){
    printf("SEMAFOR creating failed\n");
    return 1;
  }
  semctl(semafor_id,0,SETVAL,1); //init semafor

  pid_t pid = fork();
  if(pid < 0){
    printf("FORK FAILED\n");
  }
  else if(pid > 0){

    printf("PARENT\n");
    int i;
    if(i = sem_wait(semafor_id) < 0){
      printf("Failed wait parent\n");
      return 1;
    }else{
      int random = rand() % 80;
      printf("Generate random number: %d\n",random);
      //Try attach memory for writting     
      void* address = shmat(memory_id, NULL ,0);
      if(address == NULL){
        printf("Failed to atach memory\n");
        return 1;
      }

      struct shared_data* data = (struct shared_data*) address;
      data->random_num = random;

      if(shmdt(address) != 0){
        printf("Failed to detach shared memory\n");
      }

      sleep(2); 
    }

    if(i = sem_signal(semafor_id) < 0){
      printf("Failed signal parent\n");
    }else{
      printf("Parent leave generating number\n");
    }

    //wait for child
    wait(&status);
    printf("Destroy semafor\n");
    semctl(semafor_id,0, IPC_RMID,0);
    printf("Destroy shared memory\n");
    shmctl(memory_id,IPC_RMID, 0);

    return 0; 
  }
  else{
    printf("CHILD\n");
    int j;
    //try to get semafor
    if(j = sem_wait(semafor_id) < 0){
      printf("FAILED wait child\n");
    }else{
      printf("Child reading data\n");
      void* address = shmat(memory_id, NULL ,0);
      if(address == NULL){
        printf("Failed to atach memory in child\n");
        return 1;
      }

      struct shared_data* data = (struct shared_data*) address;
      printf("Child read data %d\n",data->random_num);
      sleep(1);

      if(shmdt(address) != 0){
        printf("Failed to detach shared memory in child\n");
      }
    }   

    if(j = sem_signal(semafor_id) < 0){
      printf("Failed signal child\n");
    }else{
      printf("Leave data reading\n");
    }
    return 0;
  }

  return 0;
}

共有1个答案

陶英纵
2023-03-14
void* address = shmat(memory_id, NULL ,0);

我在这一行上得到了这个错误(另一个错误是shmat):

warning: initialization makes pointer from integer without a cast

手册页显示shmat返回一个void指针,因此这是出错的线索。事实证明,添加这一行(以获得丢失的原型)可以修复它:

#include <sys/shm.h>

编辑:上面取代了之前的一个回答,那是一个红鲱鱼。

 类似资料:
  • 我想创建一个共享内存和信号量的C程序。应该有两个子进程。两个孩子都有一个不同的int数。然后有一个目标号码,应该写在共享内存中。现在两个孩子都应该从进球数中减去他们的数字,直到进球数低于或等于0。我不希望出现比赛条件。这就是为什么我尝试使用信号量。但对我没用。下面是我的代码:

  • 我尝试编写一个共享内存和信号量程序,该程序一直运行到按下Ctrl+C,即接收到: 当按下Ctrl+C时,被设置为,它会跳出循环并退出。在没有共享内存和信号量的情况下,这可以很好地工作,但是在这里,我从来没有在上获得字符串,只捕获并且它继续运行。 为什么?

  • 我需要编写一个程序,它正在创建N个数量的子进程,每一个进程都将一个添加到共享内存变量中。我的想法是使用信号量和共享内存,但进程之间并没有相互等待,共享内存变量也没有像我希望的那样工作。 MyDefs.H Main.C 奴隶Proc.c

  • null 有3个信号量:互斥-初始化为1满-初始化为0空-初始化为n(而n是管道中的“字节”数) 消费者代码: 生产者代码: 如有任何帮助,不胜感激,谢谢!

  • 程序应该创建200000个整数,并将2000个写入共享内存。分叉进程应该从共享内存中读取2000,父进程应该将下一个2000写入共享内存。 请帮帮我们谢谢你们 编辑:非常感谢您的回答。我不能标出正确的答案,因为我不知道什么是正确的。但我不想再尝试了。15个小时就够了