如何为以下代码进行进程同步？

Question

我一直在尝试做一些多线程和进程同步。我正在使用 fork 创建一个父进程和一个子进程。

如何实现父子同步以及我必须使用什么类型的同步？

我尝试了互斥锁，但以死锁结束。

// class1 threadfunction
void Class1::threadFunction()
{
    while(1)
    {
        std::cout<<"IN CLASS 1 FUNCTION\n\n";
        i++;
        sleep(2);
    }
}

//class 2 threadfunction
void Class2::threadFunction()
{
    while(1)
    {
        std::cout<<"IN CLASS 2 FUNCTION\n\n";
        j++;
        sleep(2);
    }
}

void Class1::create1()
{
    std::thread newThread (threadFunction);
    newThread.join();
}

void Class2::create2()
{
    std::thread newThread (threadFunction);
    newThread.join();
}

//main function

int main()
{
    std::cout<<"In Main\n\n";
    if(fork())
    {
        Class1 class1Object;
        class1Object.create1();
    }

    else
    {
        Class2 class2Object;
        class2Object.create2();
    }
}

我希望输出是连续的 例如：

IN CLASS 1 FUNCTION
IN CLASS 2 FUNCTION
IN CLASS 1 FUNCTION
IN CLASS 2 FUNCTION
IN CLASS 1 FUNCTION
IN CLASS 2 FUNCTION
IN CLASS 1 FUNCTION
IN CLASS 2 FUNCTION

。 . . .

Answer 1

同意@LorenzZhao——您应该考虑线程化并与互斥锁或信号量同步。

请注意，如果分叉是唯一的选择，您将需要两个进程都可以访问的共享内存。这可以像他们共享的文件或共享内存段一样简单。无论哪种情况，您都需要构建一个类似互斥体的结构。

编辑：根据@RbMm 的说明，如果您试图获得序列化同步，互斥锁和信号量可能是错误的方法。您可以考虑一个标志变量，以便线程仅在标志处于给定状态时运行，否则休眠；这也意味着当线程完成其操作时，它需要将标志变量转换为其后续状态。这也可以在不同进程之间的共享内存中完成。