src/common.h @@ -140,6 +140,7 @@ int operator()(){return msg_.size();} virtual ~_ps(){ t_quit_.store(true, std::memory_order_relaxed); cv_msg_.notify_all(); if (t_.joinable()) t_.join(); }