std :: thread :: объединение блоков на неопределенное время из основного

Question

std::thread::join не возвращается, даже если процедура потока завершена.

Угадайте, у меня есть класс.

class A 
{ 
public: 
    A() 
    { 
     this->thr = std::thread(&A::foo, this); 
    } 
    ~A() 
    { 
     this->join(); 
    } 
    void join() 
    { 
     this->cond.notify_all(); 
     if (this->thr.joinable()) 
     { 
      this->thr.join(); 
     } 
    } 

private: 
    void foo() 
    { 
     std::mutex mtx; 
     std::unique_lock<std::mutex> lck(mtx); 
     this->cond.wait(lck); 
     MessageBox(L"I'm done!"); 
    } 

private: 
    std::thread thr; 
    std::condition_variable cond; 
}; 

Мое приложение содержит единственный экземпляр A. Это глобальная переменная. Если A::join вызывается из деструктора, std::thread::join блоки навсегда. Если я вызываю A::join вручную (например, перед выходом main), все в порядке.

Мои main выглядит следующим образом:

A a; 
int main() 
{ 
    auto timeout = std::chrono::seconds(3); 
    std::this_thread::sleep_for(timeout); 

    // a.join(); 
} 

Кстати, MessageBox всегда выполняется.

Это та же проблема, что и here?

Answer 1

Да, это та же ошибка, что и в ссылке, так как ваш пример также зависает на _Thrd_join. Вас так же могут заинтересовать: this question, который содержит гораздо более подробный анализ.

Answer 2

от вашего комментария

«Это, кажется, не быть отличным решением. Я работает, но что, если основная не так тривиально? Там вы много различных способов выхода из мое приложение .Таким образом, мне нужно присоединяться к моим потокам вручную каждый раз, когда мне нужен ? "

Как насчет того, чтобы сделать A std :: unique_ptr в вашем главном. таким образом, независимо от того, как ваши основные выходы, он всегда будет уничтожать A перед выходом из main(), и у вас не будет этой проблемы.