QEventLoop을 std :: thread에 올바르게 임베드하는 방법은 무엇입니까?

Question

개체가 소멸 될 때 끝내려는 std::thread을 포함하는 개체가 있습니다.

최소한의 작업 코드 : 그것은 복잡 매우 빠르게된다

#include <thread> 
#include <future> 
#include <QEventLoop> 

struct Connector 
{ 
    Connector(std::string addr, std::function<void(std::string)> cb) 
    { 
     std::promise<void> barrier; 
     auto fut = barrier.get_future(); 

     m_worker = std::thread([addr, cb, &barrier]() 
     { 
      QEventLoop loop; 
      QTimer::singleShot(0, [this, &barrier, &loop] 
      { 
       m_quit = [&loop] { QTimer::singleShot(0, &loop, &QEventLoop::quit); }; 
       barrier.set_value(); 
      }); 

      MySocket s(addr, cb); 

      loop.exec(); 
     }); 

     fut.wait(); 
    } 

    ~Connector() 
    { 
     m_quit(); 
     m_worker.join(); 
    } 

    std::thread worker; 
    std::function<void()> m_quit; 
}; 

: 당신이이 exec() 입력 후에 만 ​​loop에 exit()를 호출 할 수 있습니다, 당신은 스레드의 loop 외부를 만들 수 없습니다.

이 루프에서 실행을 위해 대기중인 처리기에서 해제 한 세마포어가있는 해결 방법 만 있습니다. 세마포어가 해제되면 필자는 루프가 생성되어 실행 중이라는 것을 확신 할 수 있으므로 필요한 경우 quit() 메시지로 종료 될 수 있습니다.

더 간단한 방법이 없습니까?

Answer 1

아마도 QEventLoop의 unique_ptr에 대한 참조를 해당 포인터의 스레드 및 종료 호출 종료에 전달할 수 있습니다. 이처럼 :

#include <thread> 
#include <QEventLoop> 

struct Connector 
{ 
    Connector() 
    { 
     m_worker = std::thread([=]() 
     { 
      event_loop = std::make_unique<QEventLoop>(); 
      loop->exec(); 
     }); 
    } 

    ~Connector() 
    { 
     event_loop->exit(); 
     m_worker.join(); 
    } 

    std::unique_ptr<QEventLoop> event_loop; 
    std::thread worker; 
}; 

Answer 2

여기 스레드 생성자가 완료 시간에 의해 실행되고 있는지 확인하기 위해 katrasnikj의 대답과 std::promise docs에 따라 거기에 필자가 있습니다.

struct Connector 
{ 
    Connector() 
    { 
     std::promise<void> barrier; 
     auto fut = barrier.get_future(); 
     worker = std::thread([=](std::promise<void>&& barrier) 
     { 
      event_loop = std::make_unique<QEventLoop>(); 
      barrier.set_value(); 
      event_loop->exec(); 
     }, std::move(barrier)); 
     fut.wait(); 
    } 

    ~Connector() 
    { 
     QTimer::singleShot(0, event_loop.get(), &QEventLoop::quit); 
     worker.join(); 
    } 

    std::unique_ptr<QEventLoop> event_loop; 
    std::thread worker; 
}; 

하지만 당신은 자신의 이벤트 루프를 실행할 수이기 때문에, 대신 QThread을 사용하여 조사 할 수 있습니다.