多类中的多线程

Multi-Threads inside Multi-Classes

本文关键字:多线程      更新时间:2023-10-16

我想运行两个线程,每个线程对应一个。但我希望他们是独立的。例如,我有这样的东西:

class A
{
    pthread_t threadA;
    void runThreadA() { pthread_create(... arguments_here ...)};
}
class B
{
    pthread_t threadB;
    void runThreadB() { pthread_create(... arguments_here ...)};
}

目前,我为每个类在内部创建并运行两个线程,但我的主要线程是这样的:

main()
{
    A.runThreadA();
    B.runThreadB();
    pthread_join(threadA, NULL);
    pthread_join(threadB, NULL);
    return 0;
}

如何在内部也加入两个线程,导致两个线程并行运行?

希望我是可以理解的。谢谢

我将把这个作为一个答案,因为我还没有发表评论的特权,但我会尽力而为。我将解释为,当您在内部说连接线程时,您的意思是在类内部并自动连接,而无需在 main 函数中编写额外的连接行。简而言之,答案是肯定的。您可以从类内部调用 join,但这样做有些无效,原因如下。

让我们考虑这个例子(我将使用 std::thread,因为我对它更满意,但 pthread 的工作方式非常相似):

class1
{
    std::thread *t1;
    void DoWork1();
    void CreateThread1() { 
        t1= new std::thread(&class1::DoWork1, this)
        JoinThread1();
    }
    void JoinThread1(){
        if (t1.joinable()) {
            t1.join();
        }
    }
};
class2
{
    std::thread *t2;
    void DoWork2();
    void CreateThread2() { 
        t2= new std::thread(&class2::DoWork2, this)
        JoinThread2();
    }
    void JoinThread2(){
        if (t2.joinable()) {
            t2.join();
        }
    }
};

现在,从理论上讲,我们已经完成了这个目标,即每次我们调用Class1::CreateThread()它也将自动加入,而无需在主线程中增加该join()调用的需要。除了我们必须记住,join()是一个阻塞函数。因此,如果我们在main()中调用Class1::CreateThread(),那么它将阻塞,直到线程完成并加入,然后才能调用Class2::CreateThread() 。因此,如果我们尝试这种方法,很明显线程没有并行运行,并且首先使用线程也没有任何好处。

类的析构函数中调用join()有一个论点,但你仍然需要在某个地方调用该析构函数,所以我们仍然没有得到我认为你正在寻找的相同的自动化。

这个例子非常简单,但它希望能显示一些重要的东西。无论你在类中的哪个位置实现这个功能来加入线程,它要么会阻止你使用你的主线程做其他事情,比如创建第二个线程(从而破坏线程的大部分目的),要么你将不得不调用这个成员函数,无论如何都要从你的主线程手动加入线程, 唯一的区别是它将是类的成员函数,而不是您在上面示例中所拥有的。

TLDR 由于join()是一个阻塞函数,因此必须"手动"调用它,以确保您可以从线程中获得任何好处。