doładowanie asio asynchronicznie oczekujące na zmienną warunku

Question

Czy można wykonać asynchroniczne oczekiwanie (odczyt: nieblokujące) na zmiennej warunkowej w boost :: asio? jeśli nie jest obsługiwany bezpośrednio, docenione zostaną wszelkie wskazówki dotyczące jego implementacji.

Mogę zaimplementować zegar i uruchomić budzenie nawet co kilka ms, ale to podejście jest znacznie gorsze, trudno mi uwierzyć, że zmienna synchronizacja warunków nie jest zaimplementowana/udokumentowana.

Answer 1

Jeśli dobrze rozumiem intencji, chcesz uruchomić procedurę obsługi zdarzeń, gdy niektóre zmienne warunku jest sygnalizowane, w kontekście puli wątku Asio? Myślę, że byłoby to wystarczające, aby czekać na zmiennej warunkowej na początku procedury obsługi i io_service::post() sama z powrotem w basenie w końcu coś z tego rodzaju:

#include <iostream> 
#include <boost/asio.hpp> 
#include <boost/thread.hpp> 
boost::asio::io_service io; 
boost::mutex mx; 
boost::condition_variable cv; 
void handler() 
{ 
    boost::unique_lock<boost::mutex> lk(mx); 
     cv.wait(lk); 
    std::cout << "handler awakened\n"; 
    io.post(handler); 
} 
void buzzer() 
{ 
    for(;;) 
    { 
     boost::this_thread::sleep(boost::posix_time::seconds(1)); 
     boost::lock_guard<boost::mutex> lk(mx); 
      cv.notify_all(); 
    } 
} 
int main() 
{ 
    io.post(handler); 
    boost::thread bt(buzzer); 
    io.run(); 
}