 adaa6266fe
			
		
	
	adaa6266fe
	
	
	
		
			
			git-svn-id: https://llvm.org/svn/llvm-project/libcxx/trunk@120057 91177308-0d34-0410-b5e6-96231b3b80d8
		
			
				
	
	
		
			66 lines
		
	
	
		
			1.5 KiB
		
	
	
	
		
			C++
		
	
	
	
	
	
			
		
		
	
	
			66 lines
		
	
	
		
			1.5 KiB
		
	
	
	
		
			C++
		
	
	
	
	
	
| //===----------------------------------------------------------------------===//
 | |
| //
 | |
| //                     The LLVM Compiler Infrastructure
 | |
| //
 | |
| // This file is dual licensed under the MIT and the University of Illinois Open
 | |
| // Source Licenses. See LICENSE.TXT for details.
 | |
| //
 | |
| //===----------------------------------------------------------------------===//
 | |
| 
 | |
| // <mutex>
 | |
| 
 | |
| // class timed_mutex;
 | |
| 
 | |
| // template <class Clock, class Duration>
 | |
| //     bool try_lock_until(const chrono::time_point<Clock, Duration>& abs_time);
 | |
| 
 | |
| #include <mutex>
 | |
| #include <thread>
 | |
| #include <cstdlib>
 | |
| #include <cassert>
 | |
| 
 | |
| std::timed_mutex m;
 | |
| 
 | |
| typedef std::chrono::steady_clock Clock;
 | |
| typedef Clock::time_point time_point;
 | |
| typedef Clock::duration duration;
 | |
| typedef std::chrono::milliseconds ms;
 | |
| typedef std::chrono::nanoseconds ns;
 | |
| 
 | |
| void f1()
 | |
| {
 | |
|     time_point t0 = Clock::now();
 | |
|     assert(m.try_lock_until(Clock::now() + ms(300)) == true);
 | |
|     time_point t1 = Clock::now();
 | |
|     m.unlock();
 | |
|     ns d = t1 - t0 - ms(250);
 | |
|     assert(d < ns(5000000));  // within 5ms
 | |
| }
 | |
| 
 | |
| void f2()
 | |
| {
 | |
|     time_point t0 = Clock::now();
 | |
|     assert(m.try_lock_until(Clock::now() + ms(250)) == false);
 | |
|     time_point t1 = Clock::now();
 | |
|     ns d = t1 - t0 - ms(250);
 | |
|     assert(d < ns(5000000));  // within 5ms
 | |
| }
 | |
| 
 | |
| int main()
 | |
| {
 | |
|     {
 | |
|         m.lock();
 | |
|         std::thread t(f1);
 | |
|         std::this_thread::sleep_for(ms(250));
 | |
|         m.unlock();
 | |
|         t.join();
 | |
|     }
 | |
|     {
 | |
|         m.lock();
 | |
|         std::thread t(f2);
 | |
|         std::this_thread::sleep_for(ms(300));
 | |
|         m.unlock();
 | |
|         t.join();
 | |
|     }
 | |
| }
 |