diff options
author | Dan Goodliffe <dan@randomdan.homeip.net> | 2021-08-22 13:58:49 +0100 |
---|---|---|
committer | Dan Goodliffe <dan@randomdan.homeip.net> | 2021-08-22 13:58:49 +0100 |
commit | 172567f6ee168846b41d11ed7b8bd9c1ccbb659b (patch) | |
tree | 31cb78c4dedc32e9629815b855ecc7bedfcaf0b0 /test/semaphore.cpp | |
parent | Add EventCounter class (diff) | |
download | mygrate-172567f6ee168846b41d11ed7b8bd9c1ccbb659b.tar.bz2 mygrate-172567f6ee168846b41d11ed7b8bd9c1ccbb659b.tar.xz mygrate-172567f6ee168846b41d11ed7b8bd9c1ccbb659b.zip |
Wait on specific events being processed
Diffstat (limited to 'test/semaphore.cpp')
-rw-r--r-- | test/semaphore.cpp | 37 |
1 files changed, 0 insertions, 37 deletions
diff --git a/test/semaphore.cpp b/test/semaphore.cpp deleted file mode 100644 index b7e089f..0000000 --- a/test/semaphore.cpp +++ /dev/null @@ -1,37 +0,0 @@ -#include "semaphore.h" - -#ifndef __cpp_lib_semaphore -# include <thread> - -semaphore::semaphore(unsigned int v_) : v {v_} { } - -void -semaphore::release(unsigned int n) -{ - std::lock_guard lk {m}; - v += n; -} - -void -semaphore::acquire() -{ - while (!try_dec()) { } -} - -bool -semaphore::try_dec() -{ - m.lock(); - if (v) { - v--; - m.unlock(); - return true; - } - else { - m.unlock(); - std::this_thread::sleep_for(std::chrono::milliseconds(100)); - return false; - } -} - -#endif |