Энтони Уильямс - Параллельное программирование на С++ в действии. Практика разработки многопоточных программ
- Название:Параллельное программирование на С++ в действии. Практика разработки многопоточных программ
- Автор:
- Жанр:
- Издательство:ДМК Пресс
- Год:2012
- Город:Москва
- ISBN:978-5-94074-448-1
- Рейтинг:
- Избранное:Добавить в избранное
-
Отзывы:
-
Ваша оценка:
Энтони Уильямс - Параллельное программирование на С++ в действии. Практика разработки многопоточных программ краткое содержание
Книга «Параллельное программирование на С++ в действии» не предполагает предварительных знаний в этой области. Вдумчиво читая ее, вы научитесь писать надежные и элегантные многопоточные программы на С++11. Вы узнаете о том, что такое потоковая модель памяти, и о том, какие средства поддержки многопоточности, в том числе запуска и синхронизации потоков, имеются в стандартной библиотеке. Попутно вы познакомитесь с различными нетривиальными проблемами программирования в условиях параллелизма.
Параллельное программирование на С++ в действии. Практика разработки многопоточных программ - читать онлайн бесплатно полную версию (весь текст целиком)
Интервал:
Закладка:
Результат
Атомарно разблокирует предоставленный объект lock
и блокирует поток, пока он не будет разбужен обращением к notify_one()
или notify_all()
из другого потока, либо функция Clock::now()
не вернет время, большее или равное absolute_time
, либо не произойдёт ложное пробуждение. Перед возвратом управления из wait_until()
объект lock
снова блокируется.
Возвращаемое значение
std::cv_status::no_timeout
, если поток был разбужен в результате обращения к notify_one()
или notify_all()
либо ложного пробуждения. В противном случае std::cv_status::timeout
.
Исключения
Исключение типа std::system_error
, если действие не выполнено. Если объект lock
был разблокирован при обращении к wait_for()
, он снова блокируется при выходе из нее, даже если выход произошёл в результате исключения.
Примечание. Ложное пробуждение означает, что поток, вызвавший wait_until()
, может быть разбужен, даже если ни один другой поток не обращался к notify_one()
или notify_all()
. Поэтому рекомендуется использовать перегруженный вариант wait_until()
, который принимает предикат. Если это нежелательно, то рекомендуется вызывать wait_until()
в цикле, где проверяется предикат, ассоциированный с условной переменной. Не дается никаких гарантий относительно того, сколько времени будет блокирован вызывающий поток. Гарантируется лишь, что если функция вернула false
, то значение, возвращенное Clock::now()
, больше или равно absolute_time
в точке, где поток разблокировался.
Синхронизация
Обращения к функциям notify_one()
, notify_all()
, wait()
, wait_for()
и wait_until()
одного и того же объекта std::condition_variable_any
сериализуются. Обращение к notify_one()
или notify_all()
будит только потоки, запущенные до этого обращения.
STD::CONDITION_VARIABLE_ANY::WAIT_UNTIL
, ПЕРЕГРУЖЕННАЯ ФУНКЦИЯ-ЧЛЕН, ПРИНИМАЮЩАЯ ПРЕДИКАТ
Ожидает, пока условная переменная std::condition_variable_any
но лучит сигнал в результате обращения к notify_one()
или notify_all()
, и при этом предикат равен true
, либо будет достигнут указанный момент времени.
Объявление
template
typename Duration, typename Predicate>
bool wait_until(
Lockable& lock,
std::chrono::time_point const& absolute_time,
Predicate pred);
Предусловия
Выражение pred()
должно быть допустимо и возвращать значение, преобразуемое в тип bool
. Тип Lockable
удовлетворяет требованиям концепции Lockable
и lock
владеет блокировкой.
Результат
Эквивалентно следующему коду:
while (!pred()) {
if (wait_until(lock, absolute_time) == std::cv_status::timeout)
return pred();
}
return true;
Возвращаемое значение
true
, если последнее обращение к pred()
вернуло true
; false
, если функция Clock::now()
вернула время, большее или равное absolute_time
, и обращение к pred()
вернуло false
.
Примечание. Возможность ложного пробуждения означает, что функция pred
может вызываться несколько раз (сколько именно, не определено). При любом вызове pred
мьютекс, на который ссылается объект lock
, гарантированно будет захвачен, и функция вернет управление тогда и только тогда, когда результатом вычисления (bool)pred()
является true
или функция Clock::now()
вернула время, большее или равное absolute_time
. Не дается никаких гарантий относительно того, сколько времени будет блокирован вызывающий поток. Гарантируется лишь, что если функция вернула false
, то значение, возвращенное Clock::now()
, больше или равно absolute_time
в точке, где поток разблокировался.
Исключения
Исключение, возбужденное в результате обращения к pred
, или std::system_error
, если действие не выполнено.
Синхронизация
Обращения к функциям notify_one()
, notify_all()
, wait()
, wait_for()
и wait_until()
одного и того же объекта std::condition_variable_any
сериализуются. Обращение к notify_one()
или notify_all()
будит только потоки, запущенные до этого обращения.
D.3. Заголовок
В заголовке объявлены простые атомарные типы и операции над ними, а также шаблон класса для построения атомарной версии определённого пользователем типа, удовлетворяющего некоторым условиям.
Содержимое заголовка
#define ATOMIC_BOOL_LOCK_FREE см. описание
#define ATOMIC_CHAR_LOCK_FREE см. описание
#define ATOMIC_SHORT_LOCK_FREE см. описание
#define ATOMIC_INT_LOCK_FREE см. описание
#define ATOMIC_LONG_LOCK_FREE см. описание
#define ATOMIC_LLONG_LOCK_FREE см. описание
#define ATOMIC_CHAR16_T_LOCK_FREE см. описание
#define ATOMIC_CHAR32_T_LOCK_FREE см. описание
#define ATOMIC_WCHAR_T_LOCK_FREE см. описание
#define ATOMIC_POINTER_LOCK_FREE см. описание
#define ATOMIC_VAR_INIT(value) см. описание
namespace std {
enum memory_order;
struct atomic_flag;
typedef см. описание atomic_bool;
typedef см. описание atomic_char;
typedef см. описание atomic_char16_t;
typedef см. описание atomic_char32_t;
typedef см. описание atomic_schar;
typedef см. описание atomic_uchar;
typedef см. описание atomic_short;
typedef см. описание atomic_ushort;
typedef см. описание atomic_int;
typedef см. описание atomic_uint;
typedef см. описание atomic_long;
typedef см. описание atomic_ulong;
typedef см. описание atomic_llong;
typedef см. описание atomic_ullong;
typedef см. описание atomic_wchar_t;
typedef см. описание atomic_int_least8_t;
typedef см. описание atomic_uint_least8_t;
typedef см. описание atomic_int_least16_t;
typedef см. описание atomic_uint_least16_t;
typedef см. описание atomic_int_least32_t;
typedef см. описание atomic_uint_least32_t;
typedef см. описание atomic_int_least64_t;
typedef см. описание atomic_uint_least64_t;
typedef см. описание atomic_int_fast8_t;
typedef см. описание atomic_uint_fast8_t;
typedef см. описание atomic_int_fast16_t;
typedef см. описание atomic_uint_fast16_t;
typedef см. описание atomic_int_fast32_t;
typedef см. описание atomic_uint_fast32_t;
typedef см. описание atomic_int_fast64_t;
typedef см. описание atomic_uint_fast64_t;
typedef см. описание atomic_int8_t;
typedef см. описание atomic_uint8_t;
typedef см. описание atomic_int16_t;
typedef см. описание atomic_uint16_t;
typedef см. описание atomic_int32_t;
typedef см. описание atomic_uint32_t;
typedef см. описание atomic_int64_t;
typedef см. описание atomic_uint64_t;
typedef см. описание atomic_intptr_t;
typedef см. описание atomic_uintptr_t;
typedef см. описание atomic_size_t;
Интервал:
Закладка: