boost :: asio 및 strands를 사용한 이벤트 대기열 : 새 이벤트 대기

Question

그래서 사용자 정의 스레드에서 C++로 동기 이벤트 대기열을 만들고 싶습니다. 늘어나는만큼, boost :: asio :: strand는 이것에 대한 탁월한 후보이다. asio :: run()이 호출되면, 가닥의 큐에 이벤트가있는 동안에 만 실행된다. 코드 :

this->control_strand_.reset(new boost::asio::strand(control_io_service_)); 
control_thread_ = boost::thread(boost::bind(&boost::asio::io_service::run,&control_io_service_)); 
control_thread_.join(); 

즉시 반환. 이제 나는 Boost Asio - How to know when the handler queue is empty?의 대답으로 갈 수 있지만, 여기에는 while-loop-wait가 있습니다. 차라리 더 많은 이벤트를 기반으로 할 수 있습니다 (일명 대기열이 비어있는 동안 잠시 동안 "포장"통화를 기다립니다). 일이 유일한 방법 나는 그것을 할 때마다 "포장"신호를 트리거 가진 완전히 가닥 클래스를 래핑되어이 일을 생각할 수 이것은 잠시없이 영원히 큐를 실행

//some member variables 
boost::condition_variable cond_var; 
boost::mutex mut; 
std::unique_ptr<boost::asio::strand> control_strand_; 
boost::asio::io_service control_io_service_ 
//while loop,running on event processing thread 
void MessageProcessor() 
{ 
    while (true) 
    { 
    { 
     boost::unique_lock<boost::mutex> lock(mut); 
     cond_var.wait(lock); 
    } 
    control_io_service_.run(); 
    } 
} 
//post call,from different thread 
template <typename Handler> 
void wrap(Handler hand) 
{ 
    cond_var.notify_all(); 
    control_strand_->wrap(hand); 
} 

(뭔가 같은 의사 코드)라고 루프 (내 동기화 조금 떨어져,하지만 문제가 atm). 더 나은, 표준, 방법 있는가?

Answer 1

io_service을 직접 사용할 수 있으며 "암시 적 가닥"을 구현합니다. 계속 실행하려면 io_servicereference과 같이 io_service::work 개체를 지정하십시오 ("io_service가 작동하지 않도록 중지"참조).

io_service은 의도적으로 스레드로부터 안전하므로 외부 스레드에서 post() 펑터를 사용할 수 있습니다.