给定一个 boost::asio::io_service io
在启动线程以外的线程上调用 io.post(...)
是否安全 io.run()
?
例如:
boost::asio::io_service io;
void f()
{
/* do something */
io.post(&f);
}
void g()
{
/* do something else */
io.post(&g)
}
int main()
{
std::thread t1(&f);
std::thread t2(&g);
io.run();
t1.join();
t2.join();
return 0;
}
我假设io_service
使用某种内部数据结构(例如队列)并且发布会改变该数据结构(例如推送到队列上)。我担心的是数据结构可能是也可能不是线程安全的。
我已经四处搜索,但无法找到这个问题的直接答案,尽管我所看到的一切似乎都表明 post()
是线程安全的(即原子)。有人可以验证一下吗?
最佳答案
io_service::post
是线程安全的,从不同线程发布就可以了(通常需要在多线程 asio 环境中执行此操作)。
但是您的示例有一点竞争条件:
io.run()
可能会在子线程开始运行之前完成,因此在发布任何内容之前。
如果您想避免它需要 run() 直到满足特定的停止条件(例如从发布的处理程序发出信号)。 io_service::work
也可以提供帮助。
关于c++ - boost::asio::io_service::post 是原子的吗?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/51859895/