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();
Throws:system_error когда требуется исключение ([thread.req.exception]).
~condition_variable();
Requires: Не должно быть блокировок резьбы*this. [ Note: То есть все потоки должны быть уведомлены; впоследствии они могут заблокировать блокировку, указанную в ожидании. Это ослабляет обычные правила, которые требовали бы, чтобы все вызовы ожидания выполнялись до уничтожения. Только уведомление для разблокировки ожидания должно произойти до уничтожения. Пользователь должен позаботиться о том, что ни один из потоков не ждать*this когда был запущен деструктор, особенно когда ожидающие потоки вызова функции ожидания в цикле или с использованием перегрузокwait,wait_forилиwait_until что взять предикат. ] — end note
void notify_one() noexcept;
void notify_all() noexcept;
void wait(unique_lock<mutex>& lock);
Requires:lock.owns_lock() являетсяtrue иlock.mutex() заблокирован вызывающим потоком, и либо
никакой другой поток не ожидает этогоcondition_variable объекта или
lock.mutex() возвращает то же значение для каждого изlock аргументов , поставляемых всех одновременно ожидания ( с помощьюwait, wait_forилиwait_untilнитей).
Remarks: Если функция не удовлетворяет постусловию,terminate() должна быть вызвана ([except.terminate]). [ Note: Это может произойти, если повторная блокировка мьютекса вызывает исключение. ] — end note
template <class Predicate>
void wait(unique_lock<mutex>& lock, Predicate pred);
Requires:lock.owns_lock() являетсяtrue иlock.mutex() заблокирован вызывающим потоком, и либо
никакой другой поток не ожидает этогоcondition_variable объекта или
lock.mutex() возвращает то же значение для каждого изlock аргументов , поставляемых всех одновременно ожидания ( с помощьюwait, wait_forилиwait_untilнитей).
Remarks: Если функция не удовлетворяет постусловию,terminate() должна быть вызвана ([except.terminate]). [ Note: Это может произойти, если повторная блокировка мьютекса вызывает исключение. ] — end note
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() заблокирован вызывающим потоком, и либо
никакой другой поток не ожидает этогоcondition_variable объекта или
lock.mutex() возвращает то же значение для каждого изlock аргументов , поставляемых всех одновременно ожидания ( с помощьюwait, wait_forилиwait_untilнитей).
Effects:
Атомарно звонитlock.unlock() и блокируется*this.
При разблокировке вызываетlock.lock() (возможно, блокировку по блокировке), затем возвращается.
Функция разблокируется при получении сигнала от вызоваnotify_one(), вызоваnotify_all(), истечения абсолютного тайм-аута ([thread.req.timing]), указанного с помощьюabs_time, или ложно.
Если функция завершается через исключение, онаlock.lock() должна вызываться до выхода из функции.
Remarks: Если функция не удовлетворяет постусловию,terminate() должна быть вызвана ([except.terminate]). [ Note: Это может произойти, если повторная блокировка мьютекса вызывает исключение. ] — end note
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() заблокирован вызывающим потоком, и либо
никакой другой поток не ожидает этогоcondition_variable объекта или
lock.mutex() возвращает то же значение для каждого изlock аргументов , поставляемых всех одновременно ожидания ( с помощьюwait,wait_forили wait_untilнитей).
Returns:cv_status::timeout если истек относительный тайм-аут ([thread.req.timing]), указанный вrel_time , в противном случаеcv_status::no_timeout.
Remarks: Если функция не удовлетворяет постусловию,terminate() должна быть вызвана ([except.terminate]). [ Note: Это может произойти, если повторная блокировка мьютекса вызывает исключение. ] — end note
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() заблокирован вызывающим потоком, и либо
никакой другой поток не ожидает этогоcondition_variable объекта или
lock.mutex() возвращает то же значение для каждого изlock аргументов , поставляемых всех одновременно ожидания ( с помощьюwait, wait_forилиwait_untilнитей).
Effects: Эквивалентен:
while (!pred()) if (wait_until(lock, abs_time) == cv_status::timeout) return pred(); return true;
Remarks: Если функция не удовлетворяет постусловию,terminate() должна быть вызвана ([except.terminate]). [ Note: Это может произойти, если повторная блокировка мьютекса вызывает исключение. ] — end note
[ 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() заблокирован вызывающим потоком, и либо
никакой другой поток не ожидает этогоcondition_variable объекта или
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
Remarks: Если функция не удовлетворяет постусловию,terminate() должна быть вызвана ([except.terminate]). [ Note: Это может произойти, если повторная блокировка мьютекса вызывает исключение. ] — end note
[ Note: Возвращенное значение указывает, оценивается ли предикатtrue независимо от того, был ли установлен тайм-аут. ] — end note
Throws: Исключения, связанные с тайм-аутом ([thread.req.timing]) или любое исключение, созданноеpred.