33 Thread support library [thread]

33.5 Condition variables [thread.condition]

33.5.3 Class condition_variable [thread.condition.condvar]

namespace std {
  class condition_variable {
  public:

    condition_variable();
    ~condition_variable();

    condition_variable(const condition_variable&) = delete;
    condition_variable& operator=(const condition_variable&) = delete;

    void notify_one() noexcept;
    void notify_all() noexcept;
    void wait(unique_lock<mutex>& lock);
    template <class Predicate>
      void wait(unique_lock<mutex>& lock, Predicate pred);
    template <class Clock, class Duration>
      cv_status wait_until(unique_lock<mutex>& lock,
                           const chrono::time_point<Clock, Duration>& abs_time);
    template <class Clock, class Duration, class Predicate>
      bool wait_until(unique_lock<mutex>& lock,
                      const chrono::time_point<Clock, Duration>& abs_time,
                      Predicate pred);

    template <class Rep, class Period>
      cv_status wait_for(unique_lock<mutex>& lock,
                         const chrono::duration<Rep, Period>& rel_time);
    template <class Rep, class Period, class Predicate>
      bool wait_for(unique_lock<mutex>& lock,
                    const chrono::duration<Rep, Period>& rel_time,
                    Predicate pred);

    using native_handle_type = implementation-defined; // See [thread.req.native]
    native_handle_type native_handle();                // See [thread.req.native]
  };
}

Классcondition_variable должен быть классом стандартной компоновки (пункт[class]).

condition_variable();

Effects: Создает объект типаcondition_variable.

Throws:system_error когда требуется исключение ([thread.req.exception]).

Error conditions:

(4.1)
resource_unavailable_try_again - если какое-то ограничение ресурсов, не связанных с памятью, препятствует инициализации.

~condition_variable();

Requires: Не должно быть блокировок резьбы*this. [ Note: То есть все потоки должны быть уведомлены; впоследствии они могут заблокировать блокировку, указанную в ожидании. Это ослабляет обычные правила, которые требовали бы, чтобы все вызовы ожидания выполнялись до уничтожения. Только уведомление для разблокировки ожидания должно произойти до уничтожения. Пользователь должен позаботиться о том, что ни один из потоков не ждать*this когда был запущен деструктор, особенно когда ожидающие потоки вызова функции ожидания в цикле или с использованием перегрузокwait,wait_forилиwait_until что взять предикат. ] — end note

Effects: Разрушает объект.

void notify_one() noexcept;

Effects: Если какие-либо потоки заблокированы в ожидании*this, разблокирует один из этих потоков.

void notify_all() noexcept;

Effects: Разблокирует все потоки, которые заблокированы в ожидании*this.

void wait(unique_lock<mutex>& lock);

Requires:lock.owns_lock() являетсяtrue иlock.mutex() заблокирован вызывающим потоком, и либо

(9.1)
никакой другой поток не ожидает этогоcondition_variable объекта или
(9.2)
lock.mutex() возвращает то же значение для каждого изlock аргументов , поставляемых всех одновременно ожидания ( с помощьюwait, wait_forилиwait_untilнитей).

Effects:

(10.1)
Атомарно звонитlock.unlock() и блокируется*this.
(10.2)
При разблокировке вызываетlock.lock() (возможно, блокировку по блокировке), затем возвращается.
(10.3)
Функция разблокируется при получении сигнала отnotify_one() вызоваnotify_all(), вызова или ложного сигнала .

Remarks: Если функция не удовлетворяет постусловию,terminate() должна быть вызвана ([except.terminate]). [ Note: Это может произойти, если повторная блокировка мьютекса вызывает исключение. ] — end note

Postconditions:lock.owns_lock() являетсяtrue иlock.mutex() заблокирован вызывающим потоком.

Throws: Ничего такого.

template <class Predicate> void wait(unique_lock<mutex>& lock, Predicate pred);

Requires:lock.owns_lock() являетсяtrue иlock.mutex() заблокирован вызывающим потоком, и либо

(14.1)
никакой другой поток не ожидает этогоcondition_variable объекта или
(14.2)
lock.mutex() возвращает то же значение для каждого изlock аргументов , поставляемых всех одновременно ожидания ( с помощьюwait, wait_forилиwait_untilнитей).

Effects: Эквивалентен:

while (!pred())
  wait(lock);

Postconditions:lock.owns_lock() являетсяtrue иlock.mutex() заблокирован вызывающим потоком.

Throws: Любое выброшенное исключениеpred.

template <class Clock, class Duration> cv_status wait_until(unique_lock<mutex>& lock, const chrono::time_point<Clock, Duration>& abs_time);

Requires:lock.owns_lock() являетсяtrue иlock.mutex() заблокирован вызывающим потоком, и либо

(19.1)
никакой другой поток не ожидает этогоcondition_variable объекта или
(19.2)
lock.mutex() возвращает то же значение для каждого изlock аргументов , поставляемых всех одновременно ожидания ( с помощьюwait, wait_forилиwait_untilнитей).

Effects:

(20.1)
Атомарно звонитlock.unlock() и блокируется*this.
(20.2)
При разблокировке вызываетlock.lock() (возможно, блокировку по блокировке), затем возвращается.
(20.3)
Функция разблокируется при получении сигнала от вызоваnotify_one(), вызоваnotify_all(), истечения абсолютного тайм-аута ([thread.req.timing]), указанного с помощьюabs_time, или ложно.
(20.4)
Если функция завершается через исключение, онаlock.lock() должна вызываться до выхода из функции.

Postconditions:lock.owns_lock() являетсяtrue иlock.mutex() заблокирован вызывающим потоком.

Returns:cv_status::timeout если истек абсолютный тайм-аут ([thread.req.timing]), указанный вabs_time , в противном случаеcv_status::no_timeout.

Throws: Исключения, связанные с тайм-аутом ([thread.req.timing]).

template <class Rep, class Period> cv_status wait_for(unique_lock<mutex>& lock, const chrono::duration<Rep, Period>& rel_time);

Requires:lock.owns_lock() являетсяtrue иlock.mutex() заблокирован вызывающим потоком, и либо

(25.1)
никакой другой поток не ожидает этогоcondition_variable объекта или
(25.2)
lock.mutex() возвращает то же значение для каждого изlock аргументов , поставляемых всех одновременно ожидания ( с помощьюwait,wait_forили wait_untilнитей).

Effects: Эквивалентен:

return wait_until(lock, chrono::steady_clock::now() + rel_time);

Returns:cv_status::timeout если истек относительный тайм-аут ([thread.req.timing]), указанный вrel_time , в противном случаеcv_status::no_timeout.

Postconditions:lock.owns_lock() являетсяtrue иlock.mutex() заблокирован вызывающим потоком.

Throws: Исключения, связанные с тайм-аутом ([thread.req.timing]).

template <class Clock, class Duration, class Predicate> bool wait_until(unique_lock<mutex>& lock, const chrono::time_point<Clock, Duration>& abs_time, Predicate pred);

Requires:lock.owns_lock() являетсяtrue иlock.mutex() заблокирован вызывающим потоком, и либо

(31.1)
никакой другой поток не ожидает этогоcondition_variable объекта или
(31.2)
lock.mutex() возвращает то же значение для каждого изlock аргументов , поставляемых всех одновременно ожидания ( с помощьюwait, wait_forилиwait_untilнитей).

Effects: Эквивалентен:

while (!pred())
  if (wait_until(lock, abs_time) == cv_status::timeout)
    return pred();
return true;

Postconditions:lock.owns_lock() являетсяtrue иlock.mutex() заблокирован вызывающим потоком.

[ Note: Возвращенное значение указывает, оценивается ли предикат true независимо от того, был ли установлен тайм-аут. ] — end note

Throws: Исключения, связанные с тайм-аутом ([thread.req.timing]) или любое исключение, созданноеpred.

template <class Rep, class Period, class Predicate> bool wait_for(unique_lock<mutex>& lock, const chrono::duration<Rep, Period>& rel_time, Predicate pred);

Requires:lock.owns_lock() являетсяtrue иlock.mutex() заблокирован вызывающим потоком, и либо

(37.1)
никакой другой поток не ожидает этогоcondition_variable объекта или
(37.2)
lock.mutex() возвращает то же значение для каждого изlock аргументов , поставляемых всех одновременно ожидания ( с помощьюwait,wait_forили wait_untilнитей).

Effects: Эквивалентен:

return wait_until(lock, chrono::steady_clock::now() + rel_time, std::move(pred));

[ Note: Блокировка отсутствует, еслиpred() изначальноtrue, даже если время ожидания уже истекло. ] — end note

Postconditions:lock.owns_lock() являетсяtrue иlock.mutex() заблокирован вызывающим потоком.

[ Note: Возвращенное значение указывает, оценивается ли предикатtrue независимо от того, был ли установлен тайм-аут. ] — end note

Throws: Исключения, связанные с тайм-аутом ([thread.req.timing]) или любое исключение, созданноеpred.

33 Thread support library [thread]

33.5 Condition variables [thread.condition]

33.5.3 Class condition_­variable [thread.condition.condvar]

33.5.3 Class condition_variable [thread.condition.condvar]