c++ - 在 1 个线程上运行的 boost::asio::io_service 如何唤醒等待条件

Question

感谢您回复 Sam Miller，但我需要在 Windows 上实现它。

看看这个例子 o 写道：

boost::mutex mut;
boost::condition_variable cond;

boost::asio::io_service io_service;

boost::asio::deadline_timer t(io_service);

void test_func()
{
    boost::mutex::scoped_lock lk(mut);
    cond.notify_all();
}

void cancel_test_func()
{
    boost::unique_lock< boost::mutex > lk(mut);
    auto canceled_timers = t.cancel();
    cond.wait(lk);
    printf("Canceled...%u.", canceled_timers);
}

int main(int argc, char* argv[])
{
  try
  {
    t.expires_from_now(boost::posix_time::seconds(5));
    t.async_wait(boost::bind(&test_func));

    io_service.post(boost::bind(cancel_test_func));

    boost::thread_group tg;
    tg.create_thread( boost::bind(&boost::asio::io_service::run, &io_service) );
    //tg.create_thread( boost::bind(&boost::asio::io_service::run, &io_service) );

    getchar();
  }
  catch (std::exception& e)
  {
    std::cerr << "Exception: " << e.what() << "\n";
  }

  return 0;
}

为了使这个例子有效（取消计时器），我需要取消注释第二个线程创建。只有一个线程，我从来没有收到通知。问题是：这种行为正常吗？

Answer 1

条件变量是一个同步概念，它不能很好地与事件循环（如io_service. 如果你想要 Linux 上的异​​步事件，请查看eventfd(2)with EFD_SEMAPHOREflag 以获得信号量语义。不知道其他平台有没有类似的接口