gpt4 book ai didi

c - 如何通过子进程之间的共享内存共享信号量?

转载 作者:太空宇宙 更新时间:2023-11-04 08:34:24 25 4
gpt4 key购买 nike

我正在尝试使用进程重现 MapReduce。我使用 shmget() 在父进程中分配共享内存,因此每个子进程都应该可以访问它。假设这 block 内存存储一个标志和一个信号量。第一个完成设置的 child 等待信号量(其初始值为 1),设置标志,然后运行 ​​reduce 方法。因此,当其他子进程发现该标志已设置时,它们应该各自退出。我没有得到预期的行为,如果有人能启发我了解下面提供的代码中发生的事情,以及它与我试图完成的事情有何不同,我将不胜感激。

在 sem_init 之后检查 errno 为我提供了 ENOSYS,根据文档这是正确的,因为我将 pshared 设置为 1。

int map_reduce(int num_proc){
int i, pid, id, sem_ret, sem_count;
size_t index, size = 1 + sizeof(sem_t);
key_t key = IPC_PRIVATE;
id = shmget(key, size, IPC_CREAT | SHM_W | SHM_R);
void *addr = shmat(id, NULL, 0);

*((char *)addr) = 0;
sem_t *sem = (sem_t *)((char *)addr + 1);
sem_count = 1;
sem_ret = sem_init(sem, 1, sem_count);
printf("%d \n", errno == ENOSYS); // this is true

for(i = 0; i < num_proc; i++){
pid = fork();
if(pid == 0){
map();
sem_ret = sem_wait(sem);
if(*((char *)addr) == 0){
*((char *)addr) = 1;
reduce();
}
sem_ret = sem_post(sem);
exit(0);
}
}

while(wait(NULL) > 0);
struct shmid_ds buf;
key = shmctl(id, IPC_RMID, &buf);
return 0;
}

这是我运行一个只调用 map_reduce(5) 的实例得到的结果。 map 和 reduce 也只是打印出 pids。

pid: 19813 mapping
pid: 19814 mapping
pid: 19815 mapping
pid: 19816 mapping
pid: 19814 reducing
pid: 19812 reducing
pid: 19815 reducing

最佳答案

ENOSYS 表示

The function sem_init() is not supported by this implementation.

pshared is nonzero, but the system does not support process-shared semaphores.

换句话说,您的系统不支持共享信号量,因此您不能使用信号量来完成您尝试跨进程边界的操作。

关于c - 如何通过子进程之间的共享内存共享信号量?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/26922816/

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