while (numUnjoined == 0) {
s = pthread_cond_wait(&threadDied, &threadMutex);
if (s!= 0)
errExitEN(s, "pthread_cond_wait");
}
for (idx = 0; idx < totThreads; idx++) {
if (thread[idx].state == TS_TERMINATED) {
s = pthread_join(thread[idx].tid, NULL);
if (s!= 0)
errExitEN(s, "pthread_join");
thread[idx].state = TS_JOINED;
numLive-;
numUnjoined-;
printf("Reaped thread %d (numLive=%d)\n", idx, numLive);
}
}
s = pthread_mutex_unlock(&threadMutex);
if (s!= 0)
errExitEN(s, "pthread_mutex_unlock");
}
exit(EXIT_SUCCESS);
}
threads/thread_multijoin.c
30.2.5. Динамически выделяемые условные переменные
Для динамической инициализации условных переменных используется функция pthread_cond_init(). Обстоятельства ее применения аналогичны тем, при которых мы динамически инициализируем мьютексы с помощью функции pthread_mutex_init() (см. подраздел 30.1.5). Иными словами, pthread_cond_init() применяется для инициализации автоматически и динамически выделенных условных переменных, а также переменных, которые выделены статически, но требуют нестандартных атрибутов.
#include
int pthread_cond_init(pthread_cond_t *
Возвращает 0 при успешном завершении или положительное число, если произошла ошибка
Аргумент cond определяет условную переменную, которую нужно инициализировать. Как и в случае с мьютексами, мы можем указать предварительно инициализированный аргумент attr, чтобы назначить условной переменной нужные атрибуты. Для инициализации атрибутов в объекте pthread_condattr_t, на который указывает attr, можно использовать разные функции из состава библиотеки Pthreads. Если аргумент attr равен NULL, условной переменной присваиваются атрибуты по умолчанию.
Стандарт SUSv3 гласит, что повторная инициализация условной переменной приводит к непредсказуемому проведению; этого не следует делать.
Когда автоматически или динамически выделенная условная переменная больше не нужна, ее необходимо удалить с помощью функции pthread_cond_destroy(). Однако если она была статически инициализирована с использованием значения PTHREAD_COND_INITIALIZER, этого можно не делать.
#include
int pthread_cond_destroy(pthread_cond_t *
Возвращает 0 при успешном завершении или положительное число, если произошла ошибка
Уничтожение условной переменной является безопасным только в том случае, если ее не ожидает ни один из потоков. Если условная переменная находится на участке динамически выделяемой памяти, ее следует уничтожить до освобождения этого участка. Автоматически выделенную условную переменную нужно уничтожать до возврата функции, в которой она выполняется.
Условную переменную, уничтоженную с помощью функции pthread_cond_destroy(), в дальнейшем можно будет повторно инициализировать, используя функцию pthread_cond_init().
Улучшенный обмен данных, который обеспечивают потоки, имеет свою цену. Для координированного доступа к общим ресурсам многопоточные приложения должны использовать инструменты синхронизации, такие как мьютексы и условные переменные. Мьютекс обеспечивает эксклюзивный доступ к разделяемому ресурсу. Условная переменная позволяет одному или нескольким потокам ожидать уведомление о том, что какой-то другой поток изменил состояние разделяемой переменной.
Ознакомьтесь с источниками, приведенными в разделе 29.10.
30.1. Измените программу из листинга 30.1 (thread_incr.c) так, чтобы каждая итерация цикла в начальной функции потока выводила текущее значение переменной glob и какой-либо идентификатор, уникальный для текущего потока. Уникальный идентификатор можно указать в виде аргумента функции pthread_create(), с помощью которой создавался поток. В данном примере это потребует изменения аргумента начальной функции — это должен быть указатель на структуру, содержащую уникальный идентификатор и граничное значение цикла. Запустите программу, перенаправив ее вывод в файл; изучите полученный результат, чтобы понять, что происходит с переменной glob, когда планировщик ядра распределяет выполнение между двумя потоками.
30.2. Реализуйте набор потокобезопасных функций, которые позволяют искать внутри несбалансированного двоичного дерева и обновлять его содержимое. Итоговая библиотека должна включать в себя функции следующего вида (назначение понятно из их названий):
initialize(tree);
add(tree, char *key, void *value);
delete(tree, char *key)
Boolean lookup(char *key, void **value)
