我正在使用 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
}
当来自 stop() 的线程正在写入时,运行 serve() 的线程是否可以从 TSimpleServer 的未受保护的 stop_ 属性中读取?
由于某种原因我忽略了这不是问题吗?任何有关同步的帮助将不胜感激。