std::condit...::notify_all(3)

πŸ“¦ version 2024.07.05, in nixpkgs unstable, opensuse-leap 16.0

πŸŽ€ NAME πŸŽ€

Okay bestie, welcome to the std::condit...::notify_all(3) page from the C++ Standard Libary manual. The header truncates the name like it’s texting with a character limit, but the full main-character name is std::condition_variable_any::notify_all. Yes, that’s the whole name: std::condition_variable_any::notify_all. Periodt.


✨ Synopsis ✨

void notify_all() noexcept;  (since C++11)

Unblocks all threads currently waiting for *this.

It’s giving β€œeverybody up, the notification is here” energy, and it’s noexcept since C++11. Slay.


πŸ’… Parameters πŸ’…

(none)

Zero parameters. Not a single one. She takes no notes and no drama.


🌸 Return value 🌸

(none)

No return value, bestie. It does the thing and exits the group chat.


πŸ¦‹ Notes πŸ¦‹

Okay so the notes are lowkey important, so stay with me.

The effects of notify_one()/notify_all() and each of the three atomic parts of wait()/wait_for()/wait_until() β€” that’s unlock+wait, wakeup, and lock β€” take place in a single total order that can be viewed as modification order of an atomic variable. The order is specific to this individual condition variable. This makes it impossible for notify_one() to, for example, be delayed and unblock a thread that started waiting just after the call to notify_one() was made. No cap, that ordering detail is the whole vibe.

The notifying thread does not need to hold the lock on the same mutex as the one held by the waiting thread(s). Doing so may be a pessimization, since the notified thread would immediately block again, waiting for the notifying thread to release the lock β€” though some implementations recognize the pattern and do not attempt to wake up the thread that is notified under lock. So yeah: holding the lock while notifying can be kinda extra, but some implementations are hip to the pattern. πŸ’…


πŸ”₯ Example πŸ”₯

Example time, and yes the comment says what it says:

// Run this code

#include <chrono>
#include <condition_variable>
#include <iostream>
#include <thread>

std::condition_variable_any cv;
std::mutex cv_m; // This mutex is used for three purposes:
                 // 1) to synchronize accesses to i
                 // 2) to synchronize accesses to std::cerr
                 // 3) for the condition variable cv
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::lock_guard<std::mutex> lk(cv_m);
        std::cerr << "Notifying...\n";
    }
    cv.notify_all();

    std::this_thread::sleep_for(std::chrono::seconds(1));

    {
        std::lock_guard<std::mutex> lk(cv_m);
        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();
}

πŸ“ Possible output πŸ“

Waiting...
Waiting...
Waiting...
Notifying...
Notifying again...
...finished waiting. i == 1
...finished waiting. i == 1
...finished waiting. i == 1

πŸ‘‘ See also πŸ‘‘

  • notify_one β€” notifies one waiting thread (public member function).
  • C documentation for cnd_broadcast.

πŸ’€ Hidden category πŸ’€

  • Pages with unreviewed LWG DR marker

mwah πŸ’‹ this little page is brought to you by http://cppreference.com, version/date 2024.06.10, and the footer name std::condit...::notify_all(3). That’s the source tea, bestie β€” sip responsibly. 🫢✨

πŸ“¦ where this page comes from