c++ std::thread.join()是什么?

bpsygsoo  于 2023-05-20  发布在  其他
关注(0)|答案(4)|浏览(167)

通过definition from C++ reference
阻塞当前线程,直到由*this标识的线程完成其执行。
那么这是否意味着当使用.join()时,当线程调用某个函数时就不需要mutex.lock()了呢?我是互斥和线程的新手,所以我有点困惑。
注意:我找到了一本书C++ Concurrency in Action,我正在阅读这本书。对于像我这样的多线程初学者来说,它写得非常好。

2vuwiymt

2vuwiymt1#

您仍然需要互斥锁和条件。联接线程使一个执行线程等待另一个线程完成运行。您仍然需要互斥锁来保护共享资源。在这个例子中,它允许main()在退出之前等待所有线程完成。

#include <iostream>
#include <thread>
#include <chrono>
#include <mutex>

using namespace std;


int global_counter = 0;
std::mutex counter_mutex;

void five_thread_fn(){
    for(int i = 0; i<5; i++){
        counter_mutex.lock();
        global_counter++;
        counter_mutex.unlock();
        std::cout << "Updated from five_thread"  << endl;
        std::this_thread::sleep_for(std::chrono::seconds(5));
    }
    //When this thread finishes we wait for it to join
}

void ten_thread_fn(){
    for(int i = 0; i<10; i++){
        counter_mutex.lock();
        global_counter++;
        counter_mutex.unlock();
        std::cout << "Updated from ten_thread"  << endl;
        std::this_thread::sleep_for(std::chrono::seconds(1));
    }
    //When this thread finishes we wait for it to join
}
int main(int argc, char *argv[]) {
    std::cout << "starting thread ten..." << std::endl;
    std::thread ten_thread(ten_thread_fn);

    std::cout << "Running ten thread" << endl;
    std::thread five_thread(five_thread_fn);

    ten_thread.join();
    std::cout << "Ten Thread is done." << std::endl;
    five_thread.join();
    std::cout << "Five Thread is done." << std::endl;
}

请注意,输出可能如下所示:

starting thread ten...
Running ten thread
Updated frUopmd atteend_ tfhrroema df
ive_thread
Updated from ten_thread
Updated from ten_thread
Updated from ten_thread
Updated from ten_thread
Updated from five_thread
Updated from ten_thread
Updated from ten_thread
Updated from ten_thread
Updated from ten_thread
Updated from ten_thread
Updated from five_thread
Ten Thread is done.
Updated from five_thread
Updated from five_thread
Five Thread is done.

由于std::cout是一个共享资源访问,因此它的使用也应该受到互斥保护。

68de4m5k

68de4m5k2#

join()停止当前线程,直到另一个线程完成。mutex会停止当前线程,直到mutex所有者释放它,或者如果它没有被锁定,则立即锁定。所以这些家伙很不一样

zdwk9cvp

zdwk9cvp3#

它阻塞当前线程,直到调用join()的线程执行完毕。
如果你没有在线程上指定join()或dettach(),那么它将导致运行时错误,因为主/当前线程将完成其执行,而创建的其他线程仍将运行。

axr492tv

axr492tv4#

std::thread.join有三个我能想到的函数和其他一些函数:
a)鼓励持续创建/终止/销毁线程,因此会影响性能并增加泄漏,线程失控,内存失控和应用程序的一般失控的可能性。
B)通过强制执行不必要的等待来填充GUI事件处理程序,导致客户讨厌的无响应的“沙漏应用程序”。
c)导致应用程序无法关闭,因为它们正在等待一个不可响应的不可中断线程的终止。
(三)其他不好的事情。
我知道您是多线程的新手,祝您一切顺利。另外,考虑到我今晚有很多Adnams Broadside,但是:
Join()和它在其他语言中的朋友,如TThread.WaitFor( Delphi ),是高效的多线程,就像Windows ME是操作系统一样。
请努力学习并理解其他多线程概念-池、任务、应用生命周期线程、通过生产者-消费者队列的线程间通信。事实上,除了Join()之外,几乎什么都有。

相关问题