drd/tests/timed_mutex.cpp

   1 #include <thread>
   2 #include <iostream>
   3 #include <chrono>
   4 #include <mutex>
   5 #include <cassert>
   6
   7 std::timed_mutex test_mutex;
   8 int global;
   9
  10 void f()
  11 {
  12     auto now=std::chrono::steady_clock::now();
  13     test_mutex.try_lock_until(now + std::chrono::seconds(11));
  14     --global;
  15     std::this_thread::sleep_for(std::chrono::seconds(1));
  16     test_mutex.unlock();
  17 }
  18
  19
  20 int main()
  21 {
  22     global = 0;
  23     std::thread t(f);
  24     std::this_thread::sleep_for(std::chrono::seconds(1));
  25     auto now=std::chrono::steady_clock::now();
  26     test_mutex.try_lock_until(now + std::chrono::seconds(11));
  27     ++global;
  28     test_mutex.unlock();
  29     t.join();
  30     assert(global == 0);
  31 }
  32