Параллельное и распределенное программирование на С++ - Хьюз Камерон

Параметр роlicy м ожет и м еть значения SCHED_OTHER, SCHED_FIFO или SCHED_RR. Параметры планирования для стратегии планирования, заданной значением SCHED_OTHER, определяются реализацией. Для страте г ии планирования, задавае м ой значения м и SCHED_FIFO и SCHED_RR, используется только один пара м етр priority.

TSP

Если определено значение _POSIX_THREAD_SPORADIC_SERVER, аргу м ент роlicy может иметь значение SCHED_SPORADIC (за исключение м функции pthread_setschedparam()). Если стратегия планирования в момент вызова этой функции не соответствовала значению SCHED_SPORADIC, то поддержка этого значения определяется реализацией, т.е. реализация может не позволить приложению динамически изменять стратегию планирования, устанавливая ee равной значению SCHED_SPORADIC. Для стратегии планирования, определяе м ой значение м SCHED_SPORADIC, устанавливаются такие пара м етры: sched_ss_low_priority, sched_ss_repl_period, sched_ss_init_budget, sched_priority и sched_ss_max_repl. Для успешного выполнения фу н кции установки пара м етров значение пара м етра sched_ss_repl_period должно быть больше или равно значению sched_ss_init_budget; в противном случае функция завершится неудачно. Кро м е того, для успешного выполнения этой функции значение пара м етра sched_ss_max_repl должно попадать во включающий диапазон [1, SS_REPL_MAX] ; в противном случае функция завершится неудачно.

При неудачном завершении функции pthread_setschedparam() параметры планирования для заданного потока изменены не будут.

Возвращаемые значения

П ри успешно м завершении функции pthread_getschedparam() Hpthread_setschedparam() возвра щ ают нулевое значение; в противно м случае — кодошибки, обозначаю щ ий ее характер.

Ошибки

Функци я pthread_getschedparam () м ожет завершитьс я неудачно, если:

[ESRCH]  з н ачение, заданное пара м етро м thread, не относится ни к од-

ному из существующих потоков.

Функция pthread_setschedparam() может завершиться неудачно, если:

[EINVAL]  значение, заданное параметром policy, или значение одного из параметров планирования, связанных со значением стратегии планирования policy, недействительно;

была сделана попытка установить для стратегии планирования или ее параметров неподдерживаемые значения;

была сделана попытка динамически изменить стратегию планирования, установив для нее значение SCHED_SPORADIC, при том, что реализация не поддерживает такое изменение;

инициатор вызова не имеет соответствующего разрешения устанавливать параметры планирования или стратегию планирования для заданного потока;

реализация не позволяет приложению модифицировать один из параметров в соответствии с заданным значением;

значение, заданное пара м етро м thread, не относится ни к одному из существующих потоков.

Эти функции не возвращают код ошибки [EINTR].

[ENOTSUP]

TSP [ENOTSUP]

[EPERM]

[EPERM]

[ESRCH]

Примеры

Отсутствуют.

Замечания по использованию

Отсутствуют.

Логическое обоснование

Отсутствует.

Будущие направления

Отсутствуют.

Смотри также

pthread_setschedprio (), sched_getparam(), sched_getscheduler (), то м Base Definitions craHjapTaIEEEStd 1003.1-2001, <pthread.h>, <sched.h>.

Последовательность внесения изменений

Функции впервые реализованы в выпуске Issue 5. Включены для согласования с расширением POSIX Threads Extension.

Issue 6

Функции pthread_getschedparam() и pthread_setschedparam() от м ечены как часть опций Threads и Thread Execution Scheduling.

Код ошибки [ENOSYS] был исключен, поскольку е г о нет с м ысла учитывать, если реализация не под д ерживает опцию Thread Execution Scheduling.

К описанию прототипа функции pthread_setschedparam() был приложен список опечаток Open Group Corrigendum U026/2, чтобы второй ар г у м ент этой функции и м ел тип int.

Для согласования со стандартом IEEE Std 1003.1d-1999 было добавлено значение стратегии планирования SCHED_SPORADIC.

В целях согласования со стандартом ISO/IEC 9899: 1999 в прототип функции pthread_getschedparam () было добавлено ключевое слово restrict.

Был добавлен список опечаток Open Group Corrigendum U047/1.

Быладобавлена интерпретация IEEE PASC 1тегрге1а1юп 1003.1 #96, отмечающая» что значения приоритета также можно установить путем вызова функции pthread_setschedprio().

pthread_join

Имя

pthread_join — функция ожидания завершения потока.

Синопсис

THR

#include <pthread.h>

int pthread_join (pthread_t thread, void **value _ptr);

Описание

Функция pthread_join() приостанавливает выполнение вызывающего потока до тех пор, пока не завершится заданный поток (если он еще не завершился). Если после удачного возвращения из функции pthread_join () параметр value_ptr не равен значению NULL значение, передавае м ое функции pthread_exit() завершающимся потоком, будет доступным в области памяти, адресуемой параметром value_ptr. Успешное выполнение функции pthread_join () означает, что заданный поток завершился. Результаты нескольких одновременных обращений к функции pthread_join (), в параметрах которых задается один и тот же поток, не определены. Если поток, вызывающий функцию pthread_join(), отменен, то заданный поток не будет выгружен.

Не определено, учитывается ли в значении {PTHREAD_THREADS_MAX} поток, который завершился, но остался отсоединенным.

Возвращаемые значения

При успешном завершении функция pthread_join () возвращает нулевое значение; в противном случае — код ошибки, обозначающий ее характер.

Ошибки

Функция pthread_join () завершится неудачно, если:

[EINVAL]  реализация обнаружила, что значение, заданное параметром thread, не относится ни к одному из присоединенных потоков;

[ESRCH]  не найден ни один поток, идентификационный номер которого (ID) соответствовал бы заданному потоку.

Функция pthread_join () может завершиться неудачно, если:

[EDEADLK]  была обнаружена взаимоблокировка или значение параметра thread соответствует вызывающему потоку.

Функция pthread_join () не возвращает код ошибки [EINTR].

Примеры

Ниже приведен пример создания потока и его удаления.

typedef struct {

int *ar;

long n;

} subarray;

void *incer (void *arg) {

long i;

for (i = О; i < ((subarray *)arg) ->n; i++) ((subarray *) arg) ->ar[i]++;

}

int main (void) {

int ar[1000000];

pthread_t th1, th2;

subarray sbl, sb2;

sbl.ar = &ar[О];

sbl.n = 500000;

(void) pthread_create(&thl, NULL, incer, &sbl);

sb2.ar = &ar[500000];

sb2.n = 500000;

(void) pthread_create(&th2, NULL, incer, &sb2);

(void) pthread_join(thl, NULL);

(void) pthread_join(th2, NULL);

return 0;

}

Замечания по использованию

Отсутствуют.

Логическое обоснование

Функция pthread_join() представляет собой удобное и полезное средство для использования в многопоточных приложениях. Конечно, программист мог бы сымитировать эту функцию, если бы она не существовала, другими средствами, например, путем передачи функции start_routine () дополнительного состояния как части аргумента. Завершающийся поток в этом случае установил бы флаг, означающий завершение, и отправил бы условную переменную, которая является частью этого состояния, а присоединяющий поток ожидал бы получения этой условной переменной. Несмотря на то что такой метод позволил бы организовать ожидание наступления более сложных условий (например, завершения сразу нескольких потоков), ожидание завершения одного потока— весьма распространенная ситуация, и поэтому «заслуживает» отдельной функции. Кроме того, включение в библиотеку функции pthread_join () никоим образом не мешает программисту самому кодировать такие сложные ожидания. Таким образом, включение функции pthread_join () в этот том стандарта IEEE Std 1003.1-2001 считается весьма полезным.