Энтони Уильямс - Параллельное программирование на С++ в действии. Практика разработки многопоточных программ

Синхронизация

Обращения к функциям notify_one(), notify_all(), wait(), wait_for()и wait_until()одного и того же объекта std::condition_variableсериализуются. Обращение к notify_one()или notify_all()будит только потоки, запущенные до этого обращения.

STD::NOTIFY_ALL_AT_THREAD_EXIT , ФУНКЦИЯ, НЕ ЯВЛЯЮЩАЯСЯ ЧЛЕНОМ КЛАССА

Пробуждает все потоки, ожидающие std::condition_variable, при завершении текущего потока.

Объявление

void notify_all_at_thread_exit(

condition_variable& cv, unique_lock lk);

Предусловия

Значение lock.owns_lock()равно true, и владельцем блокировки lockявляется вызывающий поток. Функция lk.mutex()должна возвращать такое же значение, как для любого объекта блокировки, передаваемого функциям-членам wait(), wait_for()или wait_until()объекта cvиз одновременно ожидающих потоков.

Результат

Передает владение мьютексом, захваченным lk, внутреннему объекту и планирует отправку уведомления условной переменной cvпри завершении вызывающего потока. Уведомление эквивалентно выполнению следующего кода:

lk.unlock();

cv.notify_all();

Исключения

Возбуждает исключение std::system_error, если действие не выполнено.

Примечание. Блокировка удерживается до завершения потока, поэтому необходимо предпринимать меры для предотвращения взаимоблокировки. Рекомендуется завершать вызывающий поток как можно раньше и не выполнять в нем никаких блокирующих операций.

Пользователь должен следить за тем, чтобы ожидающий поток не сделал ошибочного предположения о том, что в момент его пробуждения данный поток уже завершен, — в частности, из-за возможности ложного пробуждения. Для этого можно проверять в ожидающем потоке предикат, который может быть сделан истинным только уведомляющим потоком, причём это должно делаться под защитой мьютекса, который не освобождается до вызова notify_all_at_thread_exit .

Класс std::condition_variable_anyпозволяет потоку ждать выполнения условия. Если объект std::condition_variableможно использовать только с блокировкой типа std::unique_lock, то std::condition_variable_anyдопустимо использовать с блокировкой любого типа, удовлетворяющего требованиям концепции Lockable.

Экземпляры std::condition_variable_anyне удовлетворяют концепциям CopyAssignable, CopyConstructible, MoveAssignable, MoveConstructible.

Определение класса

class condition_variable_any {

public:

condition_variable_any();

~condition_variable_any();

condition_variable_any(

condition_variable_any const&) = delete;

condition_variable_any& operator=(

condition_variable_any const&) = delete;

void notify_one() noexcept;

void notify_all() noexcept;

template

void wait(Lockable& lock);

template

void wait(Lockable& lock, Predicate pred);

template

std::cv_status wait_until(

Lockable& lock,

const std::chrono::time_point& absolute_time);

template <

typename Lockable, typename Clock,

typename Duration, typename Predicate>

bool wait_until(

Lockable& lock,

const std::chrono::time_point& absolute_time,

Predicate pred);

template

std::cv_status wait_for(

Lockable& lock,

const std::chrono::duration& relative_time);

template <

typename Lockable, typename Rep,

typename Period, typename Predicate>

bool wait_for(

Lockable& lock,

const std::chrono::duration& relative_time,

Predicate pred);

};

STD::CONDITION_VARIABLE_ANY , КОНСТРУКТОР ПО УМОЛЧАНИЮ

Конструирует объект типа std::condition_variable_any.

Объявление

condition_variable_any();

Результат

Конструирует объект типа std::condition_variable_any.

Исключения

Исключение типа std::system_error, если сконструировать условную переменную не получилось.

STD::CONDITION_VARIABLE_ANY , ДЕСТРУКТОР

Уничтожает объект s td::condition_variable_any.

Объявление

~condition_variable_any();

Предусловия

Не существует потоков, заблокированных по *thisв обращениях к wait(), wait_for()или wait_until().

Результат

Уничтожает *this.

Исключения

Нет.

STD::CONDITION_VARIABLE_ANY::NOTIFY_ONE , ФУНКЦИЯ-ЧЛЕН

Пробуждает один из потоков, ожидающих std::condition_variable_any.

Объявление

void notify_one() noexcept;

Результат

Пробуждает один из потоков, ожидающих *this, в точке вызова. Если таких потоков нет, функция не имеет никакого эффекта.

Исключения

Исключение типа std::system_error, если действие не выполнено.

Синхронизация

Обращения к функциям notify_one(), notify_all(), wait(), wait_for()и wait_until()одного и того же объекта std::condition_variable_anyсериализуются. Обращение к notify_one()или notify_all()будит только потоки, запущенные до этого обращения.

STD::CONDITION_VARIABLE_ANY::NOTIFY_ALL , ФУНКЦИЯ-ЧЛЕН

Пробуждает все потоки, ожидающие std::condition_variable_any.

Объявление

void notify_all() noexcept;

Результат

Пробуждает все потоки, ожидающие *this, в точке вызова. Если таких потоков нет, функция не имеет никакого эффекта.

Исключения

Исключение типа std::system_error, если действие не выполнено.

Синхронизация

Обращения к функциям notify_one(), notify_all(), wait(), wait_for()и wait_until()одного и того же объекта std::condition_variable_anyсериализуются. Обращение к notify_one()или notify_all()будит только потоки, запущенные до этого обращения.

STD::CONDITION_VARIABLE::WAIT , ФУНКЦИЯ-ЧЛЕН

Ожидает, пока условная переменная std::condition_variable_anyне получит сигнал в результате обращения к notify_one()или notify_all()либо не произойдёт ложное пробуждение.

Объявление

template

void wait(Lockable& lock);

Предусловия

Тип Lockableудовлетворяет требованиям концепции Lockableи lockвладеет блокировкой.

Результат

Атомарно разблокирует предоставленный объект lockи блокирует поток, пока он не будет разбужен обращением к notify_one()или notify_all()из другого потока либо не произойдёт ложное пробуждение. Перед возвратом управления из wait()объект lockснова блокируется.

Исключения

Исключение типа std::system_error, если действие не выполнено. Если объект lockбыл разблокирован при обращении к wait(), он снова блокируется при выходе из нее, даже если выход произошёл в результате исключения.

Примечание. Ложное пробуждение означает, что поток, вызвавший wait(), может быть разбужен, даже если ни один другой поток не обращался к notify_one()или notify_all(). Поэтому рекомендуется использовать перегруженный вариант wait(), который принимает предикат. Если это нежелательно, то рекомендуется вызывать wait()в цикле, где проверяется предикат, ассоциированный с условной переменной.