Очікування|чекання| завершення роботи потоку

#include <pthread.h>

int pthread_join (pthread_t thread, void **status_addr);

Функція повертає значення 0 при успішному завершенні. У разі|в разі| помилки повертається позитивне значення (а не негативне|заперечне|, як в більшості системних викликів і функцій!), яке визначає код помилки, описаний у файлі <errno.h>. Значення системної змінної errno при цьому не встановлюється.

struct char_print_params

{

char character;

int count;

};

void *char_print(void *params)

{

struct char_print_params *p = (struct char_print_params *) params;

int i;

for (i = 0; i < p->count; i++)

fputc(p->character, stderr);

return NULL;

}

int main(int argc, char *argv[])

{

pthread_t thread1_id, thread2_id;

struct char_print_params thread1_args, thread2_args;

thread1_args.character = 'x';

thread1_args.count = 2000;

pthread_create(&thread1_id, NULL, &char_print, &thread1_args);

thread2_args.character = 'o';

thread2_args.count = 2000;

pthread_create(&thread2_id, NULL, &char_print, &thread2_args);

pthread_join(thread1_id, NULL);

pthread_join(thread2_id, NULL);

fprintf(stderr, "\n");

return 0;

}

Канали як спосіб міжпроцесової взаємодії

Неіменовані канали

Неіменований канал є|з'являється,являється| засобом|коштом| взаємодії між зв'язаними процесами - батьківським і дочірнім. Батьківський процес створює канал за допомогою системного виклику:

int pipe(int fd[2]);

int read(int pipe_fd, void *area, int cnt); int write(int pipe_fd, void *area, int cnt);

Перший аргумент цих викликів - дескриптор каналу, другий - покажчик на область пам'яті, з|із| якою відбувається|походить| обмін, третій, - кількість байт. Обидва виклики повертають число переданих байт (або -1 - при помилці).

При завершенні використання каналу процес виконує системний виклик:

int close(int pipe_fd);

Якщо батьківський процес, що створив канал, породжує декілька дочірніх процесів, то всі дочірні процеси підключені до іншого кінця каналу. Якщо, наприклад, батьківський процес виводить дані в канал, то вони "дістануться" тому дочірньому процесу, який раніше виконає системний виклик read.

Іменовані канали в Linux

Іменовані канали в Linux (у UNIX їх іноді|інколи| називають FIFO) можуть використовуватися як засіб|кошт| взаємодії між неспорідненими|родинними| і навіть видаленими|віддаленими| процесами. Такий канал має зовнішнє ім'я, яке включається в простір імен файлової системи. Тому іменований канал ще більш схожий на файл, чим неіменований. У системі канал представляється спеціальним файлом і створюється спеціальним системним викликом:

int mknod(char *name, int mode, int dev);

Цей системний виклик може використовуватися також і для створення|створіння| звичайних|звичних| файлів, каталогів і інших спеціальних файлів. Параметр name цього виклику є|з'являється,являється| покажчиком на символьний рядок, що містить|утримує| ім'я каналу (ім'я може включати також і шлях|колія,дорога|). Параметр mode визначає тип створюваного файлу і режим доступу до нього. Старші 7 біт цього числа визначають тип створюваного файлу (для іменованого каналу він може кодуватися макроконстантою: S_IFIFO, молодші 9 біт визначають права доступу "rwx" для власника (старша трійка), для групи (середня трійка), для всіх інших (молодша трійка). Так, наприклад, для каналу, який буде доступний тільки|лише| для власника, код параметра mode буде S_IFIFO|0x140, а для каналу, доступного для всіх-всіх-всіх - S_IFIFO|0x1B6. (Природно, право "x " для каналу не визначається.) Третій параметр при створенні|створінні| каналу задається 0.

Далі при роботі з|із| іменованим каналом використовуються файлові системні виклики:

int open(int *name, int oflag); int read(int pipe_fd, void *area, int cnt); int write(int pipe_fd, void *area, int cnt); int close(int pipe_fd);

Іменований канал є|з'являється,являється| постійним об'єктом, він зберігається навіть після|потім| завершення процесу, що створив його, і при необхідності повинен бути знищений явно - за допомогою системного виклику:

int unlink(char *name);