hi_water
hi_water
maximum
lo_water
Функциональные параметры пула определяют:
context_alloc()
context_free()
THREAD_POOL_PARAM_T
#ifndef THREAD_POOL_PARAM_T
#define THREAD_POOL_PARAM_T void
#endif
В качестве контекста может использоваться любой пользовательский тип, и он будет передаваться последовательно в качестве параметра (
ctp
block_func()
context_alloc()
handler_func()
int
handler_func()
block_func()
handler_func()
block_func()
В текущей реализации
handler_func()
unblock_func()
NULL
2. После создания атрибутной записи пула, определяющей всю функциональность его дальнейшего поведения, можно приступать к непосредственному созданию пула потоков:
thread_pool_t* thread_pool_create(
thread_pool_attr_t* attr, unsigned flags);
где
attr
flags
thread_pool_start()
•
POOL_FLAG_EXIT_SELF
thread_pool_start()
•
POOL_FLAG_USE_SELF
thread_pool_start()
И в том и в другом случае в типовом фрагменте (как и в показанном выше примере):
thread_pool_start(tpp);
exit(EXIT_SUCCESS);
управление никогда не дойдет до выполнения exit(). Но существует еще третье допустимое значение, прямо не указанное в документации, но мельком упоминаемое в других местах документации:
•
0
thread_pool_start()
Например, некоторый фрагмент кода мог бы выглядеть так:
thread_pool_attr_t att; // ...
thread_pool_t *tpp = thread_pool_create(&attr, 0);
thread_pool_start(tpp);
while (true) {
// выполнять некоторую отличную от пула работу
}
exit(EXIT_SUCCESS);
Как уже понятно из описаний,
thread_pool_create()
thread_pool_start()
NULL
errno
ENOMEM
Управляющая структура пула потоков описана так:
typedef struct _thread_pool thread_pool_t;
struct _thread_pool {
thread_pool_attr_t pool_attr;
unsigned created;
unsigned waiting;
unsigned flags;
unsigned reserved[3];
};
3. Последний шаг в процедуре запуска пула потоков:
int thread_pool_start(void* pool);
где
pool
thread_pool_create()
При успешном завершении (которого почти никогда не происходит, за исключением значения флага
0
EOK
-1
4. Другие, относящиеся к библиотеке динамического пула потоков функции, которые целесообразно посмотреть в документации QNX (но которые в силу различных обстоятельств используются гораздо реже):
int thread_pool_destroy(thread_pool_t* pool);
int thread_pool_control(thread_pool_t* pool, thread_pool_attr_t* attr,
_Uint16t lower, _Uint16t upper, unsigned flags);
40
Вы спросите, почему указатель, возвращаемый
thread_pool_create()
thread_pool_t*
thread_pool_start()
void*