for (int i = 0; i < T; i++)
if (pthread_create(tid + i, NULL, threadfunc, NULL) != EOK)
cout << 'thread create error', exit(EXIT_FAILURE);
// и дожидаться их завершения ...
for (int i = 0; i < T; i++)
pthread_join(tid[i], NULL);
exit(EXIT_SUCCESS);
}
Результаты выполнения программы:
# nice -n-19 p5t -n100
2 : cycles - 79490; on sched - 397
3 : cycles - 78350; on sched — 391
# nice -n-19 p5t -n1000
2 : cycles - 753269; on sched - 376
3 : cycles - 752069; on sched - 376
# nice -n-19 p5t -n10000
2 : cycles - 7494255; on sched - 374
3 : cycles - 7493225; on sched - 374
# nice -n-19 p5t -n100000
2 : cycles - 74897795; on sched - 374
3 : cycles - 74895800; on sched — 374
# nice -n-19 p5t -n1000000
2 : cycles - 748850811, on sched - 374
3 : cycles - 748850432; on sched - 374
Как и в случае с процессами, результаты отличаются очень высокой устойчивостью при изменении «объема вычислений» на 4 порядка, однако по своим величинам значения для потоков почти в 2 раза меньше, чем для процессов (стр. 45).
Завершение потока
Как и в случае обсуждавшегося ранее завершения процесса, для потоков мы будем отчетливо различать случаи:
• «естественного» завершения выполнения потока из кода самого потока;
• завершения потока извне, из кода другого потока или по сигналу. Для этого действия, в отличие от «естественного» завершения, будем использовать другой термин — отмена.
Завершение потока происходит при достижении функцией потока своего естественного конца и выполнения оператора return (явно или неявно) или выполнения потоком вызова:
void pthread_exit(void* value_ptr)
где value_ptr — указатель на результат выполнения потока.
При выполнении pthread_exit() поток завершается. Если этот поток принадлежит к категории ожидаемых, он может возвратить результат своей работы другому потоку, ожидающему его завершения на вызове pthread_join() (только один поток может получить результат завершения). Если же этот поток отсоединенный, то по его завершении все системные ресурсы, задействованные потоком, освобождаются немедленно.
Перед завершением потока будут выполнены все завершающие процедуры, помещенные в стек завершения, а также деструкторы собственных данных потока, о которых мы говорили ранее. Для последнего потока процесса вызов pthread_exit() эквивалентен exit().
Возврат результата потока
Выше отмечено, что вызов pthread_exit(), завершающий ожидаемый поток, может передать результат выполнения потока. То же действие может быть выполнено и оператором return потоковой функции, которая из прототипа ее определения должна возвращать значение типа void*.
В обоих случаях результат может иметь сколь угодно сложный структурированный тип; никакая типизация результата не предусматривается (тип void*). Важно, чтобы код, ожидающий результата на вызове pthread_join(), понимал его так же, как и функция потока, возвращающая этот результат.
Другим условием является то, что переменная «результат» должна существовать к моменту вызова pthread_join(), то есть вполне возможно, что уже далеко после завершения самой функции ожидаемого потока. Этому условию не удовлетворяют, например, любые локальные для функции потока объекты, размещаемые в стеке. Приведем пример часто допускаемой ошибки. Следующая функция потока практически обречена на ошибку защиты памяти:
void* threadfunc(void* data) {
int res; // результат некоторых вычислений
res = ...
pthread_exit(&res);
}
А вот один из многих допустимых вариантов:
void* threadfunc(void* data) {
struct data *res = new struct; // результат некоторых вычислений
...
*res = ...
pthread_exit(res);
}
...
pthread_t tid;
pthread_create(&tid, NULL, threadfunc, NULL);
struct data *res;
pthread_join(tid, &res);
...
delete res;
Недостатком этого варианта является то, что память под блок данных результата выделяется в одной программной единице (в функции потока), а освобождаться должна в другой (в коде, ожидающем результата), при этом сами программные единицы могут размещаться даже в различных файлах исходного кода. (Здесь ситуация зеркально подобна ранее рассмотренному случаю передачи параметров в функцию создаваемого потока.)
Уничтожение (отмена) потока
Корректное завершение выполняющегося потока «извне», из другого потока (то есть асинхронно
