| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| |
|
| | |
| |
|
| | #include <semaphore> |
| | #include <thread> |
| | #include <chrono> |
| |
|
| | #include "test_macros.h" |
| |
|
| | int main(int, char**) |
| | { |
| | auto const start = std::chrono::steady_clock::now(); |
| |
|
| | std::counting_semaphore<> s(0); |
| |
|
| | assert(!s.try_acquire_until(start + std::chrono::milliseconds(250))); |
| | assert(!s.try_acquire_for(std::chrono::milliseconds(250))); |
| |
|
| | std::thread t([&](){ |
| | std::this_thread::sleep_for(std::chrono::milliseconds(250)); |
| | s.release(); |
| | std::this_thread::sleep_for(std::chrono::milliseconds(250)); |
| | s.release(); |
| | }); |
| |
|
| | assert(s.try_acquire_until(start + std::chrono::seconds(2))); |
| | assert(s.try_acquire_for(std::chrono::seconds(2))); |
| | t.join(); |
| |
|
| | auto const end = std::chrono::steady_clock::now(); |
| | assert(end - start < std::chrono::seconds(10)); |
| |
|
| | return 0; |
| | } |
| |
|