我正在使用 Thrift 框架来处理几个应用之间的 IPC。
我似乎想解决一个轻微的竞争条件问题,但这个解决方案也引发了一个线程安全问题。
TSimpleServer(Thrift 代码)的代码如下所示:
void TSimpleServer::serve()
{
// ...
while(!stop_) { // ... }
}
void TSimpleServer::stop()
{
stop_ = true;
// ...
}
因此,如果我启动一个运行此函数的新线程:
void workerFunction()
{
// server is of type TSimpleServer
server.serve(); // blocks here
}
然后尝试从不同的线程停止它:
void StopServer()
{
server.stop(); // called from a separate thread
}
难道运行 serve() 的线程可以从 TSimpleServer 的未 protected stop_ 属性读取而来自 stop() 的线程正在写入它吗?
由于某种原因我忽略了这不是问题吗?非常感谢任何有关同步的帮助。
最佳答案
这应该不是问题。对适合处理器字(4 或 8 字节)的属性对齐变量的任何写入都是原子的。换句话说,当另一个线程正在写入它时,不可能读取它的值。所以,代码是完全正确的。
关于c++ - Apache Thrift,线程安全的 TSimpleServer stop() 调用,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/13828000/