4

我正在寻找在写入者偏向的读取器/写入器模型中在两个（或多个）进程之间有效共享数据块的最佳方法。

我目前的测试是boost::interprocess. 我已经创建了一些managed_shared_memory，并试图通过使用存储在共享内存中的进程间互斥锁来锁定对数据块的访问。

但是，即使在sharable_lockreader 和upgradable_lockwriter 上使用，客户端也会在写入操作期间读取碎片值而不是阻塞。在单个进程中的线程之间进行类似的读取器/写入器设置时，我曾经upgrade_to_unique_lock解决过这个问题。但是，我还没有找到它的boost::interprocess等价物。一个存在吗？

服务器（作者）：

while (1) {
  // Get upgrade lock on the mutex
  upgradable_lock <MutexType> lock(myMutex);

  // Need 'upgrade_to_unique_lock' here so shared readers will block until
  // write operation is finished.

  // Write values here
}

客户（读者）

while (1)
{
  // Get shared access
  sharable_lock <MutexType> lock(myMutex);

  // Read p1's data here -- occasionally invalid!
}

我想手头更大的问题是：进程间互斥锁甚至是在写入器偏向设置中访问进程之间共享内存的正确方法吗？

注意：使用 Boost 1.44.0

4

2 回答 2

3

所有 Boost.Interprocess 可升级锁都支持按this升级。定义在这里。

关于您更广泛的问题-我认为这正是您想要的。读取器仍然可以同时工作，并且您必须防止并发写入。除非您可以对共享内存进行分区以保证更多的受限访问，否则这看起来是最好的。

于 2010-11-11T18:34:37.870 回答
0

OP的解决方案。

如问题评论中所述，答案是使用成员函数unlock_upgradable_and_lock。如果有 的boost::interprocess类比upgrade_to_unique_lock，我不知道它在哪里。但是writer()函数可以重写为：

while (1) {
  // Get upgrade lock on the mutex
  myMutex.lock_upgradable();

  // Get exclusive access and block everyone else
  myMutex.unlock_upgradable_and_lock();

  // Write values here

  // Unlock the mutex (and stop blocking readers)
  myMutex.unlock();
}
于 2017-08-29T17:23:07.170 回答