用html做静态网站,可以做软件的网站有哪些功能吗,网站建设及推广话术,肇庆搞产品网站的公司std::jthread
说明#xff1a;
std::jthread 是 C20 中引入的一个新特性#xff0c;它是线程库中的一个类#xff0c;专门用于处理 std::thread 与 std::stop_token 和 std::stop_source 之间的交互#xff0c;以支持更优雅和安全的线程停止机制。
std::stop_source控制…std::jthread
说明
std::jthread 是 C20 中引入的一个新特性它是线程库中的一个类专门用于处理 std::thread 与 std::stop_token 和 std::stop_source 之间的交互以支持更优雅和安全的线程停止机制。
std::stop_source控制线程标记。相当于g_bQuitFlag true;
std::stop_token线程函数内检测结束标记。相当于while(!g_bQuitFlag){...};
作用1.可控制的线程结束防止人工封装的线程结束控制变量不是线程安全的。2.线程结束后不必手工调用join();
源码简单赏析
C:\Program Files (x86)\Microsoft Visual Studio\2019\Enterprise\VC\Tools\MSVC\14.29.30133\include\thread
下面代码可以复制出来浏览。
class jthread {
public:using id thread::id;using native_handle_type thread::native_handle_type;jthread() noexcept : _Impl{}, _Ssource{ nostopstate } {}template class _Fn, class... _Args, enable_if_t!is_same_vremove_cvref_t_Fn, jthread, int 0_NODISCARD_CTOR explicit jthread(_Fn _Fx, _Args... _Ax) {if constexpr (is_invocable_vdecay_t_Fn, stop_token, decay_t_Args...) //线程函数第一个参数为stop_token如果客户端std::jthread jt(work, stop_source.get_token());使用自己的stop_source展开相当于//is_invocable_vdecay_t_Fn, stop_token, stop_token为false执行下面else为不使用this-_Ssource,这里很微妙//如果客户端std::jthread jt(work);不使用自己的stop_source展开相当于is_invocable_vdecay_t_Fn, stop_token为true//也就是说这个if判断了三种情况1.线程函数第一个不为stop_token 2.线程函数第一个参数为stop_token且客户端使用自己的stop_source //3.线程函数第一个参数为stop_token且客户端使用不自己的stop_source{_Impl._Start(_STD forward_Fn(_Fx), _Ssource.get_token(), _STD forward_Args(_Ax)...);//按照使用this内置的stop_source::stop_token传给线程函数}else {_Impl._Start(_STD forward_Fn(_Fx), _STD forward_Args(_Ax)...);//按照std::thread处理不使joinable功能那么this-request_stop();也无效。处于兼容性考虑吧}}~jthread() {_Try_cancel_and_join();//析构时可自动调用_Impl.joinable();_Ssource.request_stop();_Impl.join();}jthread(const jthread) delete;//不支持拷贝构造jthread(jthread) noexcept default;//jthread依然是unique thread类型的jthread operator(const jthread) delete;//不支持赋值jthread operator(jthread _Other) noexcept {// note: the standard specifically disallows making self-move-assignment a no-op here// N4861 [thread.jthread.cons]/13// Effects: If joinable() is true, calls request_stop() and then join(). Assigns the state// of x to *this and sets x to a default constructed state._Try_cancel_and_join();//移动赋值时先结束掉本线程再移动源线程到this_Impl _STD move(_Other._Impl);_Ssource _STD move(_Other._Ssource);return *this;}//剩下的简单函数封装void swap(jthread _Other) noexcept {_Impl.swap(_Other._Impl);_Ssource.swap(_Other._Ssource);}_NODISCARD bool joinable() const noexcept {return _Impl.joinable();}void join() {_Impl.join();}void detach() {_Impl.detach();}_NODISCARD id get_id() const noexcept {return _Impl.get_id();}_NODISCARD stop_source get_stop_source() noexcept {return _Ssource;}_NODISCARD stop_token get_stop_token() const noexcept {return _Ssource.get_token();}bool request_stop() noexcept {return _Ssource.request_stop();}friend void swap(jthread _Lhs, jthread _Rhs) noexcept {_Lhs.swap(_Rhs);}_NODISCARD static unsigned int hardware_concurrency() noexcept {return thread::hardware_concurrency();}private:void _Try_cancel_and_join() noexcept {if (_Impl.joinable()) {_Ssource.request_stop();_Impl.join();}}thread _Impl;//采用c组合方式对std::thread进行薄薄的封装,是不是和std::queue差不多的方法stop_source _Ssource;//使用std自己实现的原子操作类std::stop_source控制线程停止
};应用
根据源代码阅读衍生的几个例子。源代码和例子说的是一致的。
1.不使用jthread内置的stop_source相当于thread类,std::jthread::request_stop();将不起作用方便于一个外置std::stop_source控制多个线程函数
#include iostream
#include thread
#include chronovoid work(std::stop_token stop_token) {while (!stop_token.stop_requested()) {std::cout Working...\n;std::this_thread::sleep_for(std::chrono::seconds(1));}std::cout Stopping...\n;
}int main() {std::stop_source stop_source;std::jthread jt(work, stop_source.get_token());std::this_thread::sleep_for(std::chrono::seconds(3));stop_source.request_stop();return 0;
}
2.使用jthread内置的stop_source
#include iostream
#include thread
#include chronovoid work(std::stop_token stop_token) {while (!stop_token.stop_requested()) {std::cout Working...\n;std::this_thread::sleep_for(std::chrono::seconds(1));}std::cout Stopping...\n;
}int main() {std::jthread jt(work);std::this_thread::sleep_for(std::chrono::seconds(3));//这两行都没必要人工调用的jt.request_stop();//jt.join();//return 0;
}
3.当线程函数参数没有参数stop_token时使用起来std::jthread::request_stop();不起作用。相当于std::thread
#include iostream
#include thread
#include chronovoid work() {while (1) {std::cout Working...\n;std::this_thread::sleep_for(std::chrono::seconds(1));}std::cout Stopping...\n;
}int main() {std::jthread jt(work);std::this_thread::sleep_for(std::chrono::seconds(3));jt.request_stop();jt.join();return 0;
}
//输出
//Working...
//Working...
//Working...
//Working...
//...结论
功能过于强大灵活坑也比较多。功能少呆板也没有什么坑。其实没有什么坑只不过没看过开源库源码。官方文档不足以表达就像黑盒测试永远无法相当于白盒测试。常常碰一碰运气运行一下看起来没问题黑盒看起来也没问题官方文档std::jthread - cppreference.com
