Роб Кёртен - Введение в QNX/Neutrino 2. Руководство по программированию приложений реального времени в QNX Realtime Platform

• режим блокирования;

• режим обработки.

В режиме блокирования поток обычно вообще не использует ресурсы процессора. В типовом сервере это соответствует ситуации, когда поток ждет сообщения. Противоположностью этого режима является режим обработки, в котором поток может как использовать, так и не использовать ресурсы процессора — это зависит от структуры процесса. Чуть позже мы рассмотрим функции работы с пулами потоков, и вы увидите, что они дают возможность управлять количеством как блокированных, так и обрабатывающих потоков.

Для работы с пулами потоков в QNX/Neutrino предусмотрены следующие функции:

#include

thread_pool_t *thread_pool_create(

thread_pool_attr_t *attr, unsigned flags);

int thread_pool_destroy(thread_pool_t *pool);

int thread_pool_start(void *pool);

Как видно из имен функций, вы в первую очередь создаете пул потоков, используя функцию thread_pool_create() , а затем запускаете этот пул при помощи функции thread_pool_start() . Когда вы закончили свои дела с пулом потоков, вы можете использовать функцию thread_pool_destroy() для его уничтожения. Заметьте, что функция thread_pool_destroy() может вам вообще не понадобиться — например, когда ваша программа суть сервер, который работает «вечно».

Итак, первая функция, на которую следует обратить внимание — это функция thread_pool_create() . У нее два параметра: attr и flags . Параметр attr — атрибутная запись, которая определяет рабочие параметры пула потоков (см. ):

typedef struct _thread_pool_attr {

// Функции и дескриптор пула потоков

THREAD_POOL_HANDLE_T * handle ;

THREAD_POOL_PARAM_T *(*block_func)

(THREAD_POOL_PARAM_T *ctp);

void (* unblock_func )(THREAD_POOL_PARAM_T *ctp);

int (*handler_func) (THREAD_POOL_PARAM_T *ctp);

THREAD_POOL_PARAM_T *(* context_alloc )

(THREAD_POOL_HANDLE_T *handle);

void *(* context_free )(THREAD_POOL_PARAM_T *ctp);

// Параметры пула потоков

pthread_attr_t * attr ;

unsigned short lo_water ;

unsigned short increment ;

unsigned short hi_water ;

unsigned short maximum ;

} thread_pool_attr_t;

Я разбил определение типа thread_pool_attr_t на два раздела, один из которых содержит функции и дескриптор для потоков в пуле, а в другом — рабочие параметры пула.

Сначала проанализируем «параметры пула потоков», чтобы понять, как можно управлять числом потоков в пуле и их атрибутами. Имейте в виду, что здесь мы будем говорить о «режиме блокирования» и «режиме обработки» (далее, когда мы будем рассматривать функции исходящих вызовов (callout functions), мы увидим, как эти эти режимы соотносятся).

Приведенный ниже рисунок иллюстрирует связи между параметрами lo_water, hi_water и maximum .

Жизненный цикл потока в пуле потоков.

(Заметьте, что как «CA» здесь обозначается функция context_alloc() , как «CF» — функция context_free() , как «режим блокирования» — функция block_func() , а как «режим обработки» — функция handler_func() .

Другой ключевой параметр, предназначенный для управления потоками, — это параметр flags , передаваемый функции thread_pool_create() . Он может принимать одно из следующих значений: