비동기 작업 대기

Question

비동기 작업이 완료 될 때까지 프로그램 흐름을 차단할 수있는 메커니즘을 구현하고 싶습니다. (아무런 메시지 루프가없는 곳 구름 유닛 테스트에 사용된다.)

I 가진 코드는 스레드를 생성하고 스레드 내부 상태 통지를 기다린다 :

#include <chrono> 
#include <condition_variable> 
#include <iostream> 
#include <memory> 
#include <mutex> 
#include <stdexcept> 
#include <thread> 

struct Blocker { 
    Blocker() : 
     wait_thread([this]() { 
      std::mutex mtx; 
      std::unique_lock<std::mutex> lck(mtx);    
      cond.wait(lck); 
     }) 
    { 
    } 

    void wait() { wait_thread.join(); } 

    void notify() { cond.notify_one(); } 

    std::condition_variable cond;  
    std::thread wait_thread; 
}; 

template<typename Callback> 
void async_operation(const Callback & cb) { cb(); } 

int main() { 
    Blocker b; 
    async_operation([&](){ b.notify(); }); 
    b.wait(); 
} 

문제는 그 종종 스레드가 시작되기 전에 notify에 대한 호출이 발생하기 때문에 교착 상태가 발생합니다. 이 문제를 어떻게 해결해야합니까?

Answer 1

#include <mutex> 
#include <condition_variable> 

struct blocker 
{ 
    blocker() : done (false) {} 

    void 
    notify() 
    { 
    std::unique_lock<std::mutex> lock (m); 
    done = true; 
    c.notify_all(); 
    } 

    void 
    wait() 
    { 
    std::unique_lock<std::mutex> lock (m); 
    while (!done) 
     c.wait (lock); 
    } 

    bool done; 
    std::mutex m; 
    std::condition_variable c; 
};