diff options
Diffstat (limited to 'test/thread_test.cpp')
-rw-r--r-- | test/thread_test.cpp | 32 |
1 files changed, 16 insertions, 16 deletions
diff --git a/test/thread_test.cpp b/test/thread_test.cpp index b2a8144..8c2d13a 100644 --- a/test/thread_test.cpp +++ b/test/thread_test.cpp @@ -32,12 +32,12 @@ std::atomic<int> n_errors(0); void wait_for_sem(Semaphore* sem) { - var = 41; - std::cout << "[Waiter] Waiting for signal..." << std::endl; - sem->wait(); - std::cout << "[Waiter] Received signal, exiting" << std::endl; - var = 42; - assert(var == 42); + var = 41; + std::cout << "[Waiter] Waiting for signal..." << std::endl; + sem->wait(); + std::cout << "[Waiter] Received signal, exiting" << std::endl; + var = 42; + assert(var == 42); } } // namespace @@ -45,20 +45,20 @@ wait_for_sem(Semaphore* sem) int main() { - Semaphore sem(0); - std::thread waiter(wait_for_sem, &sem); + Semaphore sem(0); + std::thread waiter(wait_for_sem, &sem); - var = 24; + var = 24; - std::cout << "[Main] Signalling..." << std::endl; - sem.post(); + std::cout << "[Main] Signalling..." << std::endl; + sem.post(); - std::cout << "[Main] Waiting for waiter..." << std::endl; - waiter.join(); + std::cout << "[Main] Waiting for waiter..." << std::endl; + waiter.join(); - std::cout << "[Main] Exiting" << std::endl; + std::cout << "[Main] Exiting" << std::endl; - assert(var == 24); + assert(var == 24); - return n_errors.load(); + return n_errors.load(); } |