thread_guard vs scoped_thread

thread_guard vs scoped_thread

本文关键字：thread scoped guard vs      更新时间：2023-10-16

在书中

《C++ Concurrency In Action》作者：Anthony Williams

你可以找到以下两个代码片段(我引入了一些轻微的修改)：

片段 1：

class thread_guard
{
std::thread& t;
public:
explicit thread_guard(std::thread& t_): t(t_){}
~thread_guard()
{
if(t.joinable())
{
t.join();
}
}
thread_guard(thread_guard const&)=delete;
thread_guard& operator=(thread_guard const&)=delete;
};
void my_func()
{
for(int j = 0; j < 1000; ++j)
{
cout << "n " << j;
}
}
void f()
{
std::thread t1(my_func);
thread_guard g(t1);
do_something_in_current_thread();
}
int main()
{
f();
return 0;
}

继续你可以找到

片段 2：

class scoped_thread
{
std::thread t;
public:
explicit scoped_thread(std::thread t_):    t(std::move(t_))
{
if(!t.joinable())
throw std::logic_error(“No thread”);
}
~scoped_thread()
{
t.join();
}
scoped_thread(scoped_thread const&)=delete;
scoped_thread& operator=(scoped_thread const&)=delete;
};
void my_func()
{
for(int j = 0; j < 1000; ++j)
{
cout << "n " << j;
}
}
void f()
{
scoped_thread st1(thread(my_func));
thread t2(my_func);
scoped_thread st2(move(t2));
do_something_in_current_thread();
}
int main()
{
f();
return 0;
}

我不确定我是否真的能体会到这两个片段之间的真正区别。

我能看到的唯一区别是，在片段 1 中，thread_guard的实例不获取线程t1的所有权(与scoped_thread对象不同)，因此可以调用t1.join()但执行~thread_guard()时这不是问题。

那么：片段 2 的优势在哪里(如果存在的话)？

这两种类型都旨在阻止销毁(例如范围退出)，直到线程完成。区别在于thread对象的所有权。

thread_guard并不拥有thread本身;可能有多个thread_guard在同一thread上等待。这也意味着只要任何thread_guard引用thread对象，它就必须处于活动状态。如果在销毁thread_guard对象时引用的线程已联接，则它不会阻塞或产生错误(而不是仅在不可联接的线程上调用join)。

另一方面，scoped_thread拥有thread实例的所有权，因此也控制其生存期。每当您想拥有要等待的线程时，您都可以使用它，例如作为数据成员。

最终，你使用哪一个是一个语义问题：你是想等待别人拥有的线程(那么你还必须确保没有生命周期问题)，还是你想要一个thread对象，当它被破坏时阻塞，而不必先join它。

就功能而言，这两种实现都能够服务器的目的，我在这两个实现中看到的唯一区别是，Snippet 2可以同时接受lvalue(glvalue)和rvalue(prvalue)但Snippet 1不能接受rvalue(prvalue)作为构造函数参数。例如，考虑以下代码，

std::thread getThread()
{
return std::thread([](){ std::cout<< __PRETTY_FUNCTION__<< std::endl;});
}
int main( int , char *[])
{
thread_guard g( getThread());
return 0;
}

现在，如果您编译此代码，编译将给出以下错误，

error: cannot bind non-const lvalue reference of type ‘std::thread&’ to an rvalue of type ‘std::remove_reference<std::thread&>::type’ {aka ‘std::thread’}
explicit thread_guard(std::thread _t): t(std::move( _t)){ std::cout<< __PRETTY_FUNCTION__<< std::endl;}

但是snippet 2实现将正常工作。

相关文章：