UNIX: взаимодействие процессов
вернуться

Стивенс Уильям Ричард
Шрифт:

56 for(;;)

57 pause;

58 }

По сравнению с листингом 15.2 было внесено четыре изменения:

1. Убрано объявление дескриптора двери fd (теперь это глобальная переменная, описанная в листинге 15.18).

2. Вызов door_create защищен взаимным исключением (также описанным в листинге 15.18).

3. Вызов door_server_create делается перед созданием двери, при этом указывается процедура создания сервера (my_thread, которая, будет показана позже).

4. В вызове door_create последний аргумент (атрибуты) имеет значение DOOR_PRIVATE вместо 0. Это говорит библиотеке о том, что данная дверь будет иметь собственный пул потоков, называемый частным пулом сервера.

Задание процедуры создания сервера с помощью door_server_create и выделение частного пула сервера с помощью DOOR_PRIVATE осуществляются независимо друг от друга. Возможны четыре ситуации:

1. По умолчанию частный пул сервера и процедура создания сервера отсутствуют. Система создает потоки по мере необходимости и они переходят в пул потоков процесса.

2. Указан флаг DOOR_PRIVATE, но процедура создания сервера отсутствует. Система создает потоки по мере необходимости и они отходят в пул потоков процесса, если относятся к тем дверям, для которых флаг DOOR_PRIVATE не был указан, либо в пул данной двери, если она была создана с флагом DOOR_PRIVATE.

3. Отсутствует частный пул сервера, но указана процедура создания сервера. Процедура создания вызывается при необходимости создания нового потока, который затем переходит в пул потоков процесса.

4. Указан флаг DOOR_PRIVATE и процедура создания сервера. Процедура создания сервера вызывается каждый раз при необходимости создания потока. После создания поток должен вызвать door_bind для отнесения его к нужному частному пулу сервера, иначе он будет добавлен к пулу потоков процесса.

В листинге 15.18 приведен текст двух новых функций: my_create (процедура создания сервера) и my_thread (функция, выполняемая каждым потоком, который создается my_create).

Листинг 15.18. Функции управления потоками

//doors/server6.c

13 pthread_mutex_t fdlock = PTHREAD_MUTEX_INITIALIZER;

14 static int fd = –1; /* дескриптор двери */

15 void *

16 my_thread(void *arg)

17 {

18 int oldstate;

19 door_info_t *iptr = arg;

20 if ((Door_server_proc*)iptr->di_proc == servproc) {

21 Pthread_mutex_lock(&fdlock);

22 Pthread_mutex_unlock(&fdlock);

23 Pthread_setcancelstate(PTHREAD_CANCEL_DISABLE, &oldstate);

24 Door_bind(fd);

25 Door_return(NULL, 0, NULL, 0);

26 } else

27 err_quit("my_thread: unknown function: %p", arg);

28 return(NULL); /* никогда не выполняется */

29 }

30 void

31 my_create(door info_t *iptr)

32 {

33 pthread_t tid;

34 pthread_attr_t attr;

35 Pthread_attr_init(&attr);

36 Pthread_attr_setscope(&attr, PTHREAD_SCOPE_SYSTEM);

37 Pthread_attr_setdetachstate(&attr, PTHREAD_CREATE_DETACHED);

38 Pthread_create(&tid, &attr, my_thread, (void *)iptr);

39 Pthread_attr_destroy(&attr);

40 printf("my_thread: created server thread %ld\n", pr_thread_id(&tid)):

41 }

Процедура создания сервера

30-41 Каждый раз при вызове my_create создается новый поток. Перед вызовом pthread_create атрибуты потока инициализируются, область потока устанавливается равной PTHREAD_SCOPE_SYSTEM и поток определяется как неприсоединенный (detached). Созданный поток вызывает функцию my_thread. Аргументом этой функции является указатель на структуру типа door_info_t. Если у нас имеется сервер с несколькими дверьми и мы указываем процедуру создания сервера, эта процедура создания сервера будет вызываться при необходимости создания потока для любой из дверей. Единственный способ, которым эта процедура может определить тип сервера, соответствующий нужной двери, заключается в изучении указателя di_proc в структуре типа door_info_t.