GThreadPool

typedef struct {
  GFunc func;
  gpointer user_data;
  gboolean exclusive;
} GThreadPool;

Структура GThreadPool представляет потоковый пул. Она имеет шесть общих доступных только для чтения элементов, но скрытая структура больше, поэтому вы не должны копировать эту структуру.

g_thread_pool_new ()

GThreadPool* g_thread_pool_new              (GFunc func,
                                             gpointer user_data,
                                             gint max_threads,
                                             gboolean exclusive,
                                             GError **error);

Эта функция создаёт новый потоковый пул.

Каждый раз при вызове g_thread_pool_push(), или создаётся новый поток или повторно используется один из неиспользуемых. Большинство max_threads потоков выполняются параллельно для этого потокового пула. max_threads = -1 позволяет безлимитное создание потоков для этого пула. Вновь созданный или повторно используемый поток выполняет функцию func с двумя аргументами. Первый для g_thread_pool_push() а второй user_data.

Параметр exclusive определяет, владеет ли всеми исключительными потоками пул, или потоки доступны глобально. Если exclusive равен TRUE, max_threads потоки начинаются немедленно и они будут выполняться исключительно для этого пула пока он не разрушен g_thread_pool_free(). Если exclusive равен FALSE, потоки создаются когда необходимы и доступны всем не исключительным потоковым пулам. Это подразумевает что max_threads может не быть -1 для исключительных потоковых пулов.

error может быть NULL для игнорирования ошибок, или не-NULL для сообщения об ошибках. Ошибка может произойти только когда exclusive установлен в TRUE и не все max_threads могут быть созданы.

g_thread_pool_push ()

void        g_thread_pool_push              (GThreadPool *pool,
                                             gpointer data,
                                             GError **error);

Вставляет data в список задач для выполнения пулом pool. Когда количество выполняемых потоков меньше чем максимально допустимое, новый поток запускается (или повторно выполняется) с параметрами полученными в g_thread_pool_new(). Иначе data остаются в очереди пока поток в этом пуле не завершит предыдущие задачи и не начнет обрабатывать data.

error может быть NULL для игнорирования ошибок, или не-NULL для сообщения об ошибках. Ошибка может произойти только когда новый поток не может быть создан. В этом случае data просто вставляются в начало очереди для выполнения.

g_thread_pool_set_max_threads ()

void        g_thread_pool_set_max_threads   (GThreadPool *pool,
                                             gint max_threads,
                                             GError **error);

Устанавливает максимально допустимое число потоков для pool. Значение -1 означает безлимитное количество потоков.

Установка max_threads в значение 0 означает полную остановку работы pool. Пул замораживается до тех пор пока значение max_threads не будет установлено в не-нулевое значение.

Поток никогда не завершается во время выполнения вызова func, которая поставляется g_thread_pool_new(). Вместо этого максимальное число потоков имеет эффект только для распределения новых потоков в g_thread_pool_push(). Новый поток распределяется каждый раз, когда текущее количество выполняемых потоков в пуле меньше pool меньше чем максимальное число.

error может быть NULL для игнорирования ошибок, или не-NULL для сообщения об ошибках. Ошибка происходит только когда новый поток не может быть создан.

g_thread_pool_get_max_threads ()

gint        g_thread_pool_get_max_threads   (GThreadPool *pool);

Возвращает максимальное число потоков для pool.

g_thread_pool_get_num_threads ()

guint       g_thread_pool_get_num_threads   (GThreadPool *pool);

Возвращает текущее количество выполняемых потоков в pool.

g_thread_pool_unprocessed ()

guint       g_thread_pool_unprocessed       (GThreadPool *pool);

Возвращает количество задач остающихся не обработанными в pool.

g_thread_pool_free ()

void        g_thread_pool_free              (GThreadPool *pool,
                                             gboolean immediate,
                                             gboolean wait);

Освобождает все ресурсы распределённые для pool.

Если immediate равен TRUE, нет новых задач обрабатываемых в pool. Иначе pool не освободиться до тех пор пока последняя задача не обработана. Однако помните, поток не прерывается в пуле пока выполняет задачу. Все потоки выполняющие свои задачи завершают их перед тем как pool будет освобождён.

Если wait равен TRUE, функции не возвращают прежде чем все обрабатываемые задачи (зависит от immediate, все или только выполняемые в текущий момент) будут готовы. Иначе функции возвращаются немедленно.

После вызова этой функции pool не должен больше использоваться.

g_thread_pool_set_max_unused_threads ()

void        g_thread_pool_set_max_unused_threads
                                            (gint max_threads);

Устанавливает максимальное количество неиспользуемых потоков в max_threads. Если max_threads равен -1, количество неиспользуемых потоков не лимитировано.

g_thread_pool_get_max_unused_threads ()

gint        g_thread_pool_get_max_unused_threads
                                            (void);

Возвращает максимально допустимое число неиспользуемых потоков.

g_thread_pool_get_num_unused_threads ()

guint       g_thread_pool_get_num_unused_threads
                                            (void);

Возвращает текущее количество неиспользуемых потоков.

g_thread_pool_stop_unused_threads ()

void        g_thread_pool_stop_unused_threads
                                            (void);

Останавливает все текущие неиспользуемые потоки. Это не меняет максимальное число неиспользуемых потоков. Эта функция может использоваться для регулярной остановки всех неиспользуемых потоков например из g_timeout_add().

g_thread_pool_set_sort_function ()

void        g_thread_pool_set_sort_function (GThreadPool *pool,
                                             GCompareDataFunc func,
                                             gpointer user_data);

Устанавливает функцию для сортировки списка задач. Это позволяет обрабатывать задачи с приоритетом определяемым с помощью func, а не только в порядке в котором они были добавлены в пул.

Помните, если максимальное количество потоков больше 1, порядок выполнения потоков не может быть гарантирован на 100%. Потоки планируются операционной системой и выполняются в случайном порядке. Не предполагайте что потоки выполняются в порядке их создания.

Начиная с версии 2.10

g_thread_pool_set_max_idle_time ()

void        g_thread_pool_set_max_idle_time (guint interval);

Эта функция устанавливает максимальный interval ожидания потоком новых задач в пуле перед остановкой. Эта функция похожа на вызов g_thread_pool_stop_unused_threads() с регулярным таймаутом, но выполняется на основании потока.

Установка interval в 0, не останавливает бездействующие потоки. Эта функция создаёт g_async_queue_timed_pop() используя interval.

Начиная с версии 2.10

g_thread_pool_get_max_idle_time ()

guint       g_thread_pool_get_max_idle_time (void);

Эта функция возвращает максимальный interval ожидания потоком новых задач в пуле перед остановкой.

Если функция вернула 0, потоки ожидающие новые задачи в пуле не останавливаются.

Начиная с версии 2.10