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;
}

Я ожидал, что внутри лямбда-функции переменная 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.