1bc8d3f97eb5c958007f2713238472e0c1c8fe02Howard Hinnant//===----------------------------------------------------------------------===// 2bc8d3f97eb5c958007f2713238472e0c1c8fe02Howard Hinnant// 3f5256e16dfc425c1d466f6308d4026d529ce9e0bHoward Hinnant// The LLVM Compiler Infrastructure 4bc8d3f97eb5c958007f2713238472e0c1c8fe02Howard Hinnant// 5b64f8b07c104c6cc986570ac8ee0ed16a9f23976Howard Hinnant// This file is dual licensed under the MIT and the University of Illinois Open 6b64f8b07c104c6cc986570ac8ee0ed16a9f23976Howard Hinnant// Source Licenses. See LICENSE.TXT for details. 7bc8d3f97eb5c958007f2713238472e0c1c8fe02Howard Hinnant// 8bc8d3f97eb5c958007f2713238472e0c1c8fe02Howard Hinnant//===----------------------------------------------------------------------===// 9bc8d3f97eb5c958007f2713238472e0c1c8fe02Howard Hinnant 10bc8d3f97eb5c958007f2713238472e0c1c8fe02Howard Hinnant// <condition_variable> 11bc8d3f97eb5c958007f2713238472e0c1c8fe02Howard Hinnant 12bc8d3f97eb5c958007f2713238472e0c1c8fe02Howard Hinnant// class condition_variable_any; 13bc8d3f97eb5c958007f2713238472e0c1c8fe02Howard Hinnant 14bc8d3f97eb5c958007f2713238472e0c1c8fe02Howard Hinnant// template <class Lock, class Clock, class Duration> 15bc8d3f97eb5c958007f2713238472e0c1c8fe02Howard Hinnant// cv_status 16bc8d3f97eb5c958007f2713238472e0c1c8fe02Howard Hinnant// wait_until(Lock& lock, const chrono::time_point<Clock, Duration>& abs_time); 17bc8d3f97eb5c958007f2713238472e0c1c8fe02Howard Hinnant 18bc8d3f97eb5c958007f2713238472e0c1c8fe02Howard Hinnant#include <condition_variable> 19bc8d3f97eb5c958007f2713238472e0c1c8fe02Howard Hinnant#include <mutex> 20bc8d3f97eb5c958007f2713238472e0c1c8fe02Howard Hinnant#include <thread> 21bc8d3f97eb5c958007f2713238472e0c1c8fe02Howard Hinnant#include <chrono> 22bc8d3f97eb5c958007f2713238472e0c1c8fe02Howard Hinnant#include <cassert> 23bc8d3f97eb5c958007f2713238472e0c1c8fe02Howard Hinnant 24bc8d3f97eb5c958007f2713238472e0c1c8fe02Howard Hinnantstruct Clock 25bc8d3f97eb5c958007f2713238472e0c1c8fe02Howard Hinnant{ 26bc8d3f97eb5c958007f2713238472e0c1c8fe02Howard Hinnant typedef std::chrono::milliseconds duration; 27bc8d3f97eb5c958007f2713238472e0c1c8fe02Howard Hinnant typedef duration::rep rep; 28bc8d3f97eb5c958007f2713238472e0c1c8fe02Howard Hinnant typedef duration::period period; 29bc8d3f97eb5c958007f2713238472e0c1c8fe02Howard Hinnant typedef std::chrono::time_point<Clock> time_point; 30f8f852138f86e4588916021e1afedfcab25298c0Howard Hinnant static const bool is_steady = true; 31bc8d3f97eb5c958007f2713238472e0c1c8fe02Howard Hinnant 32bc8d3f97eb5c958007f2713238472e0c1c8fe02Howard Hinnant static time_point now() 33bc8d3f97eb5c958007f2713238472e0c1c8fe02Howard Hinnant { 34bc8d3f97eb5c958007f2713238472e0c1c8fe02Howard Hinnant using namespace std::chrono; 35bc8d3f97eb5c958007f2713238472e0c1c8fe02Howard Hinnant return time_point(duration_cast<duration>( 36f8f852138f86e4588916021e1afedfcab25298c0Howard Hinnant steady_clock::now().time_since_epoch() 37bc8d3f97eb5c958007f2713238472e0c1c8fe02Howard Hinnant )); 38bc8d3f97eb5c958007f2713238472e0c1c8fe02Howard Hinnant } 39bc8d3f97eb5c958007f2713238472e0c1c8fe02Howard Hinnant}; 40bc8d3f97eb5c958007f2713238472e0c1c8fe02Howard Hinnant 41bc8d3f97eb5c958007f2713238472e0c1c8fe02Howard Hinnantstd::condition_variable_any cv; 42bc8d3f97eb5c958007f2713238472e0c1c8fe02Howard Hinnant 43bc8d3f97eb5c958007f2713238472e0c1c8fe02Howard Hinnanttypedef std::timed_mutex L0; 44bc8d3f97eb5c958007f2713238472e0c1c8fe02Howard Hinnanttypedef std::unique_lock<L0> L1; 45bc8d3f97eb5c958007f2713238472e0c1c8fe02Howard Hinnant 46bc8d3f97eb5c958007f2713238472e0c1c8fe02Howard HinnantL0 m0; 47bc8d3f97eb5c958007f2713238472e0c1c8fe02Howard Hinnant 48bc8d3f97eb5c958007f2713238472e0c1c8fe02Howard Hinnantint test1 = 0; 49bc8d3f97eb5c958007f2713238472e0c1c8fe02Howard Hinnantint test2 = 0; 50bc8d3f97eb5c958007f2713238472e0c1c8fe02Howard Hinnant 51bc8d3f97eb5c958007f2713238472e0c1c8fe02Howard Hinnantint runs = 0; 52bc8d3f97eb5c958007f2713238472e0c1c8fe02Howard Hinnant 53bc8d3f97eb5c958007f2713238472e0c1c8fe02Howard Hinnantvoid f() 54bc8d3f97eb5c958007f2713238472e0c1c8fe02Howard Hinnant{ 55bc8d3f97eb5c958007f2713238472e0c1c8fe02Howard Hinnant L1 lk(m0); 56bc8d3f97eb5c958007f2713238472e0c1c8fe02Howard Hinnant assert(test2 == 0); 57bc8d3f97eb5c958007f2713238472e0c1c8fe02Howard Hinnant test1 = 1; 58bc8d3f97eb5c958007f2713238472e0c1c8fe02Howard Hinnant cv.notify_one(); 59bc8d3f97eb5c958007f2713238472e0c1c8fe02Howard Hinnant Clock::time_point t0 = Clock::now(); 60bc8d3f97eb5c958007f2713238472e0c1c8fe02Howard Hinnant Clock::time_point t = t0 + Clock::duration(250); 61bc8d3f97eb5c958007f2713238472e0c1c8fe02Howard Hinnant while (test2 == 0 && cv.wait_until(lk, t) == std::cv_status::no_timeout) 62bc8d3f97eb5c958007f2713238472e0c1c8fe02Howard Hinnant ; 63bc8d3f97eb5c958007f2713238472e0c1c8fe02Howard Hinnant Clock::time_point t1 = Clock::now(); 64bc8d3f97eb5c958007f2713238472e0c1c8fe02Howard Hinnant if (runs == 0) 65bc8d3f97eb5c958007f2713238472e0c1c8fe02Howard Hinnant { 66bc8d3f97eb5c958007f2713238472e0c1c8fe02Howard Hinnant assert(t1 - t0 < Clock::duration(250)); 67bc8d3f97eb5c958007f2713238472e0c1c8fe02Howard Hinnant assert(test2 != 0); 68bc8d3f97eb5c958007f2713238472e0c1c8fe02Howard Hinnant } 69bc8d3f97eb5c958007f2713238472e0c1c8fe02Howard Hinnant else 70bc8d3f97eb5c958007f2713238472e0c1c8fe02Howard Hinnant { 71fe14b970ac1ce90da0d22aa0b83fc48298d94327Daniel Dunbar assert(t1 - t0 - Clock::duration(250) < Clock::duration(50)); 72bc8d3f97eb5c958007f2713238472e0c1c8fe02Howard Hinnant assert(test2 == 0); 73bc8d3f97eb5c958007f2713238472e0c1c8fe02Howard Hinnant } 74bc8d3f97eb5c958007f2713238472e0c1c8fe02Howard Hinnant ++runs; 75bc8d3f97eb5c958007f2713238472e0c1c8fe02Howard Hinnant} 76bc8d3f97eb5c958007f2713238472e0c1c8fe02Howard Hinnant 77bc8d3f97eb5c958007f2713238472e0c1c8fe02Howard Hinnantint main() 78bc8d3f97eb5c958007f2713238472e0c1c8fe02Howard Hinnant{ 79bc8d3f97eb5c958007f2713238472e0c1c8fe02Howard Hinnant { 80bc8d3f97eb5c958007f2713238472e0c1c8fe02Howard Hinnant L1 lk(m0); 81bc8d3f97eb5c958007f2713238472e0c1c8fe02Howard Hinnant std::thread t(f); 82bc8d3f97eb5c958007f2713238472e0c1c8fe02Howard Hinnant assert(test1 == 0); 83bc8d3f97eb5c958007f2713238472e0c1c8fe02Howard Hinnant while (test1 == 0) 84bc8d3f97eb5c958007f2713238472e0c1c8fe02Howard Hinnant cv.wait(lk); 85bc8d3f97eb5c958007f2713238472e0c1c8fe02Howard Hinnant assert(test1 != 0); 86bc8d3f97eb5c958007f2713238472e0c1c8fe02Howard Hinnant test2 = 1; 87bc8d3f97eb5c958007f2713238472e0c1c8fe02Howard Hinnant lk.unlock(); 88bc8d3f97eb5c958007f2713238472e0c1c8fe02Howard Hinnant cv.notify_one(); 89bc8d3f97eb5c958007f2713238472e0c1c8fe02Howard Hinnant t.join(); 90bc8d3f97eb5c958007f2713238472e0c1c8fe02Howard Hinnant } 91bc8d3f97eb5c958007f2713238472e0c1c8fe02Howard Hinnant test1 = 0; 92bc8d3f97eb5c958007f2713238472e0c1c8fe02Howard Hinnant test2 = 0; 93bc8d3f97eb5c958007f2713238472e0c1c8fe02Howard Hinnant { 94bc8d3f97eb5c958007f2713238472e0c1c8fe02Howard Hinnant L1 lk(m0); 95bc8d3f97eb5c958007f2713238472e0c1c8fe02Howard Hinnant std::thread t(f); 96bc8d3f97eb5c958007f2713238472e0c1c8fe02Howard Hinnant assert(test1 == 0); 97bc8d3f97eb5c958007f2713238472e0c1c8fe02Howard Hinnant while (test1 == 0) 98bc8d3f97eb5c958007f2713238472e0c1c8fe02Howard Hinnant cv.wait(lk); 99bc8d3f97eb5c958007f2713238472e0c1c8fe02Howard Hinnant assert(test1 != 0); 100bc8d3f97eb5c958007f2713238472e0c1c8fe02Howard Hinnant lk.unlock(); 101bc8d3f97eb5c958007f2713238472e0c1c8fe02Howard Hinnant t.join(); 102bc8d3f97eb5c958007f2713238472e0c1c8fe02Howard Hinnant } 103bc8d3f97eb5c958007f2713238472e0c1c8fe02Howard Hinnant} 104