让 fork 无限执行等量的次数

Make fork execute equal amounts of times, infinitely

我试图让下面的代码永远不允许 + 的数量大于 - 的数量。我正在考虑添加一个简单的 c sleep(1) 行,但我很好奇是否有更好的方法使数量相等。这应该保持无限循环。

int main(){
 if(fork() ==0)
    while(1){
       write(1,"-",1)
   }

  else
     while(1){

       write(1, "+",1);
   }

return 0;
}

使用信号量这个功能是否正确?

int main(){

int parent_sem = get_semaphore(0);
int child_sem = get_semaphore(1);

 if(fork() ==0)
    while(1){
        sem_wait(child_sem);
       write(1,"-",1);
       sem_signal(parent_sem);
   }

  else
     while(1){
       sem_wait(parent_sem);
       write(1, "+",1);
       sem_signal(child_sem);
   }

return 0;
}

这是关闭(使用信号):

#include <unistd.h>
#include <stdio.h>
#include <signal.h>

void usr1handler() {
}

int main(void) {
        int pid;

        signal(SIGUSR1, usr1handler);

        if ((pid = fork()) == 0) {
                while (1) {
                        pause();
                        write(1, "-", 1);
                        fflush(stdout);
                        kill(getppid(), SIGUSR1);
                }
        }
        else {

                sleep(1);

                while (1) {
                        write(1, "+", 1);
                        fflush(stdout);
                        kill(pid, SIGUSR1);
                        pause();
                }
        }

}

主要问题是竞争条件。如果一个进程在另一个进程进入 pause() 之前进入 kill() 函数,程序将冻结。不过,这可能足以让您开始。我在那里留下了一个睡眠,所以你可以看到它确实打印均匀。

这是您的信号量示例的固定版本。我已经分配了共享内存,以便两个进程都可以通过 fork 访问信号量(我忘了这是必要的,抱歉)并修复了信号量类型和调用。

#include <unistd.h>
#include <semaphore.h>
#include <sys/mman.h>

int main() {
    // Create shared memory for two semaphores
    sem_t* sem = mmap(NULL, 2 * sizeof(sem_t), PROT_READ | PROT_WRITE,
                      MAP_SHARED | MAP_ANONYMOUS, -1, 0);

    // Initialise parent and child semaphores: parent = 1, child = 0
    sem_t* parent_sem = sem;
    sem_t* child_sem = sem + 1;    
    sem_init(parent_sem, 1, 1);
    sem_init(child_sem, 1, 0);

    if (fork() == 0) {
        while(1) {
            // Child process
            sem_wait(child_sem);
            write(1, "-", 1);
            sem_post(parent_sem);
        }
    } else {
        while(1) {
            // Parent process
            sem_wait(parent_sem);
            write(1, "+", 1);
            sem_post(child_sem);
        }
    }

    return 0;
}