MyWackoSite: КурсОперационныеСистемы/ПрактикумPosixThreads/PthreadLectures/CreateExit ...

В ходе этого раздела вы изучите

• Создание нитей с атрибутами по умолчанию
• Передачу параметров нити
• Завершение нити
• Ожидание завершения другой нити
• Принудительное завершение нити
• Обработку принудительного завершения нити

Создание нитей с атрибутами по умолчанию

В POSIX Thread API нить создается библиотечной функцией pthread_create(3C).

Параметры этой функции:


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

Коды ошибок

Пример 1
#include <stdio.h> #include <stdlib.h> #include <pthread.h> #include <string.h> void * thread_body(void * param) { sleep(1); printf("Child\n"); } /* * creates thread with default attributes and no parameters * sleeps enough time to ensure that thread will print his message * (under reasonable conditions) */ int main(int argc, char *argv[]) { pthread_t thread; int code; int i; code=pthread_create(&thread, NULL, thread_body, NULL); if (code!=0) { char buf[256]; strerror_r(code, buf, sizeof buf); fprintf(stderr, "%s: creating thread: %s\n", argv[0], buf); exit(1); } sleep(5); return (EXIT_SUCCESS); }

Завершение нити

Для завершения нити используется функция pthread_exit(3C). Эта функция всегда завершается успешно и принимает единственный параметр, указатель на код возврата типа void *. Как и в случае с pthread_create(3C), библиотека никогда не пытается обращаться к значению этого параметра как к указателю, поэтому его можно использовать для передачи скалярных значений.

Другой способ завершения нити – это возврат управления из функции start_routine при помощи оператора return. Поскольку функция start_routine должна возвращать тип void *, все ее операторы return должны возвращать значение. Этот способ практически полностью эквивалентен вызову pthread_exit(3C) с тем же самым значением.


Пример 2
#include <pthread.h> #include <unistd.h> #include <iostream> class TestClass { public: int value; TestClass(int parameter) { std::cout << "Constructed " << parameter << "\n"; value=parameter; } ~TestClass() { std::cout << "destructed " << value << "\n"; } }; extern "C" { void *body_forexit(void * param) { TestClass a(1); sleep(1); pthread_exit((void *)a.value); return (void *)a.value; } void *body_forreturn(void * param) { TestClass b(2); sleep(2); return (void *)b.value; } } // extern "C" int main() { pthread_t thread1, thread2; pthread_create(&thread1, NULL, body_forexit, NULL); pthread_detach(thread1); pthread_create(&thread2, NULL, body_forreturn, NULL); pthread_detach(thread2); pthread_exit(NULL); return 0; }