std::condition_variable_any::notify_all
From cppreference.com
< cpp | thread | condition variable any
void notify_all(); |
(since C++11) | |
If any threads is waiting on *this, unblocks all of the waiting threads.
Contents |
[edit] Parameters
(none)
[edit] Return value
(none)
[edit] Exceptions
[edit] Example
#include <iostream> #include <condition_variable> #include <thread> #include <chrono> std::condition_variable_any cv; std::mutex cv_m; int i = 0; void waits() { std::unique_lock<std::mutex> lk(cv_m); std::cerr << "Waiting... \n"; cv.wait(lk, [](){return i == 1;}); std::cerr << "...finished waiting. i == 1\n"; } void signals() { std::this_thread::sleep_for(std::chrono::seconds(1)); std::cerr << "Notifying...\n"; cv.notify_all(); std::this_thread::sleep_for(std::chrono::seconds(1)); i = 1; std::cerr << "Notifying again...\n"; cv.notify_all(); } int main() { std::thread t1(waits), t2(waits), t3(waits), t4(signals); t1.join(); t2.join(), t3.join(), t4.join(); }
Output:
Waiting... Waiting... Waiting... Notifying... Notifying again... ...finished waiting. i == 1 ...finished waiting. i == 1 ...finished waiting. i == 1
[edit] See also
notifies one waiting thread (public member function) |