使用 fork() 的计数器不会在内部增加

Counter not increasing inside a for using fork()

我正在这里做一个小项目,其中一个部分要求我在标志打开时做一些事情,而另一部分是标志同时关闭(使用 fork())。虽然我知道这可能会带来 mutex 问题,但我似乎无法让它工作。我不认为我曾经得到过互斥体。

我的一段代码如下所示:

int i=0;
int w;
int pos=0;
pid_t pid;
char c[1];
for(i=0;i<len;i++) //len is the length of a file I'm reading. 
{
    pid=fork();
    if(pid)
    {
        wait(&w);
    }
    else
    {
        read(fd,&c,1); //fd is an int referencing a the file i'm reading. Using open(char* [], O_RDONLY);
        printf("I'm son %d, read: %s, pos value: %d\n",getpid(),c,pos);
        if(pos==0)
        {
           printf("I'm son %d, writing out in out1.txt\n",getpid());
           //some writing instructions...
           pos=1;
        }
        else
        {
           printf("I'm son %d, writing out in out2.txt\n",getpid());
           //some writing instructions...
           pos=0;
        }
        exit(0);
    }
}

问题是我总是进入同一个 if,因此,我总是只写入其中一个文件,我需要在两个文件之间交替写入。

Actual output: 
I'm son <NUMBER>, read: 0, pos value: 0
I'm son <NUMBER>, writing out in out1.txt
I'm son <NUMBER>, read: 1, pos value: 0
I'm son <NUMBER>, writing out in out1.txt
I'm son <NUMBER>, read: 0, pos value: 0
I'm son <NUMBER>, writing out in out1.txt
I'm son <NUMBER>, read: 1, pos value: 0
I'm son <NUMBER>, writing out in out1.txt
I'm son <NUMBER>, read: 0, pos value: 0
I'm son <NUMBER>, writing out in out1.txt

Desired output:
I'm son <NUMBER>, read: 0, pos value: 0
I'm son <NUMBER>, writing out in out1.txt
I'm son <NUMBER>, read: 1, pos value: 1
I'm son <NUMBER>, writing out in out2.txt
I'm son <NUMBER>, read: 0, pos value: 0
I'm son <NUMBER>, writing out in out1.txt
I'm son <NUMBER>, read: 1, pos value: 1
I'm son <NUMBER>, writing out in out2.txt
I'm son <NUMBER>, read: 0, pos value: 0
I'm son <NUMBER>, writing out in out1.txt

谢谢!

设置 pos=1 后,每个进程立即调用 exit(0),因此 pos 永远不会在打印中设置为 1。我假设它在某处被初始化为 0。请记住,fork 的每一侧都是一个完整且很大程度上独立的内存副本(一个进程)。因此,其中一个的变化不会影响其他。这可能是您想要的线程不同。

要达到你想要的效果,你必须在parent过程中控制pos。 child 所做的任何更改都是 child 的本地更改,并且在 child 退出时丢失。

int i = 0;
int w;
int pos = 0;
pid_t pid;
char c[1];
for (i = 0; i < len; i++, pos = !pos)
{
    pid = fork();
    if (pid)
    {
        wait(&w);
    }
    else
    {
        read(fd, &c, 1);
        printf("I'm son %d, read: %s, pos value: %d\n", getpid(), c, pos);
        if (pos == 0)
        {
           printf("I'm son %d, writing out in out1.txt\n", getpid());
        }
        else
        {
           printf("I'm son %d, writing out in out2.txt\n", getpid());
        }
        exit(0);
    }
}

请注意,您应该检查 fork()wait()read() 中的错误 return。我没有为你编码。另请注意,!= 不是 ! 运算符的赋值版本(与 += 不同,后者是 + 运算符的赋值版本,例如);因此,我不得不写 pos = !pos.