在1个线程上运行的boost::asio::io_service如何唤醒等待条件
How could a boost::asio::io_service running on 1 thread wake up awaiting condition
谢谢你回复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;
}
为了使这个例子起作用(取消计时器),我需要取消对第二个线程创建的注释。只有一个线程,我从来没有收到通知。问题是:这种行为正常吗?
条件变量是一个同步概念,它不能很好地与像io_service
这样的事件循环集成。如果您希望在Linux上使用异步事件,请查看带有EFD_SEMAPHORE
标志的eventfd(2)
以了解信号量语义。我不确定在其他平台上是否有类似的接口
相关文章:
- 为什么"do while"循环不断退出,即使条件计算结果为 false?
- 在没有太多条件句的情况下,我如何避免被零除
- 基于多个条件处理地图中的所有元素
- 条件constexpr函数
- 无论条件是否为true,if总是在c++中执行
- 我可以使用条件运算符初始化C风格的字符串文字吗
- 基于模板值的条件变量
- 多个If语句与使用逻辑运算符计算条件的单个语句的比较
- 将按位if条件转换为普通if条件
- 条件断点在不应该触发时触发
- 为什么简单的算术减法在"if"条件下不起作用?
- 如何在for循环中包含两个索引值的测试条件
- 如果条件为TRUE(最佳方式?),则在do while循环中后置增量
- 我提出什么条件才能再加5%的折扣
- 循环中的条件:为什么每次都调用strlen(),而vector.size()只调用一次
- 即使没有满足他们的条件,我也无法通过一些 do-while 循环
- 如何编写一个使用n倍三元条件语句的C++布尔函数
- 没有超时的C++条件变量
- 正在LLVM中检测整数比较条件
- 在条件变量中触发错误信号的频率是多少