boost::interprocess::interprocess_condition::timed_wait永远在等待

Question

我有以下最小的例子：

#include <iostream>
#include <boost/thread.hpp>
#include <boost/interprocess/sync/interprocess_condition.hpp>
#include <boost/interprocess/sync/interprocess_mutex.hpp>


int main(int argc, char* argv[]) {
  boost::interprocess::interprocess_condition ic;
  boost::interprocess::interprocess_mutex im;
  bool test = false;
  auto testFunction = [&ic, &im, &test]() {
    boost::unique_lock lk(im);
    auto tin = boost::posix_time::microsec_clock::local_time();
    auto waitTime = tin + boost::posix_time::milliseconds(100);
    if (!ic.timed_wait(lk, waitTime)) {
      test = false;
    }
    else {
      test = true;
    }
  };

  auto notifyFunction = [&ic]() {
    ic.notify_all();
  };

  boost::thread t(testFunction);
  boost::this_thread::sleep_for(boost::chrono::milliseconds(2000));
  boost::thread t2(notifyFunction);
  t.join();
  t2.join();
  std::cout << "Result is: " << std::boolalpha << test << std::endl;
  return 0;
}

我所期望的是，在lambda函数中，interprocess_condition变量ic等待100毫秒，然后函数继续执行。相反，该条件等待在第二个线程中调用的通知。

我做错了什么？我应该如何正确使用timed_wait才能等待所需的时间？

我使用的是boost版本1.72.0。

Answer 1

我已经找到解决方案了。我需要使用boost::posix_time::microsec_clock::universal_time而不是boost::posix_time::microsec_clock::local_time。