【发布时间】:2013-05-21 16:01:12
【问题描述】:
我在 Unix C 中使用共享内存、信号量和分叉时遇到问题。我的信号量不是 posix。 我创建了一个指向共享内存 2*sizeof(float) 的指针。 我用 semctl 将信号量的值初始化为 2。 我在 for 循环(i
Parent reading 0
Parent reading 1
Parent reading 0
Parent reading 1
Child writing 0
Child writing 1
什么时候我应该得到的是:
Child writing 0
Child writing 1
Parent reading 0
Parent reading 1
我尝试将我的信号量初始化为 1 而不是 2,但这只会让程序停止,因为信号量永远不会有值 2,因此父进程永远不会读取。
如果我对信号量的理解是正确的,我将它初始化为 2 的事实意味着即使没有子进程写任何东西,父进程也可以直接读取。我该如何解决这个问题?
编辑:我在请求后添加了我的代码的简化版本,我删除了错误检查,并等待孩子减少长度。
/** OPEN MEMORY **/
int shmid1 = shmget(1990, (size), IPC_CREAT | 0666 );
float * shmPt = (float*)shmat(shmid1, NULL, 0);
/** CREATE INITIALIZE SEMAPHORE **/
semun1.val = 2;
int semid = semget(1991, 1, 0666 | IPC_CREAT)
semctl(semid, 0, SETVAL, semun1 )
/** CREATE PROCESSES **/
for ( ii = 0; ii < 2; ++ii) {
if ((p = fork()) == 0) {
int semid = semget(1991, 1, 0666);
struct sembuf p_buf;
p_buf.sem_num = 0;p_buf.sem_op = -1;p_buf.sem_flg = SEM_UNDO;
/** LOCK **/
semop(semid, &p_buf,1);
/** WRITE **/
shmPt[ii] = RandomFloat;
v_buf.sem_num = 0;v_buf.sem_op = 1;v_buf.sem_flg = SEM_UNDO;
/** UNLOCK **/
semop(semid, &v_buf,1)
exit(0);
}
else {
int semid = semget(1991, 1, 0666);
struct sembuf p_buf;
p_buf.sem_num = 0;p_buf.sem_op = -2;p_buf.sem_flg = SEM_UNDO;
/** LOCK **/
semop(semid, &p_buf,1);
/** READ **/
for(int j =0;j<2;j++) tabFloat[j] = shmPt[j];
v_buf.sem_num = 0;v_buf.sem_op = 2;v_buf.sem_flg = SEM_UNDO;
/** UNLOCK **/
semop(semid, &v_buf,1)
}
}
编辑: 我的最终目标是让 24 个孩子一个一个地写到一个相同大小的共享内存段中,只有当它写满时,父母才能读取所有内容并处理信息。最重要的是,所有这些都需要在一个 while 循环中进行(想象一下 24 辆汽车在每次完成一圈时不断生成随机时间,直到第一辆汽车完成 50 圈)
【问题讨论】:
-
与其描述代码,为什么不显示给我们呢?那时你会更容易看到和理解你在做什么。
-
与其试图描述你的代码,为什么不直接发布你的代码呢? (如有必要,以简化形式。)
-
我添加了简化代码
标签: c memory fork semaphore shared