Functions
g_thread_pool_new ()
GThreadPool *
g_thread_pool_new (GFunc func,
gpointer user_data,
gint max_threads,
gboolean exclusive,
GError **error);
This function creates a new thread pool.
Whenever you call g_thread_pool_push(), either a new thread is
created or an unused one is reused. At most max_threads
threads
are running concurrently for this thread pool. max_threads
= -1
allows unlimited threads to be created for this thread pool. The
newly created or reused thread now executes the function func
with the two arguments. The first one is the parameter to
g_thread_pool_push() and the second one is user_data
.
The parameter exclusive
determines whether the thread pool owns
all threads exclusive or shares them with other thread pools.
If exclusive
is TRUE, max_threads
threads are started
immediately and they will run exclusively for this thread pool
until it is destroyed by g_thread_pool_free(). If exclusive
is
FALSE, threads are created when needed and shared between all
non-exclusive thread pools. This implies that max_threads
may
not be -1 for exclusive thread pools. Besides, exclusive thread
pools are not affected by g_thread_pool_set_max_idle_time()
since their threads are never considered idle and returned to the
global pool.
error
can be NULL to ignore errors, or non-NULL to report
errors. An error can only occur when exclusive
is set to TRUE
and not all max_threads
threads could be created.
See GThreadError for possible errors that may occur.
Note, even in case of error a valid GThreadPool is returned.
g_thread_pool_push ()
gboolean
g_thread_pool_push (GThreadPool *pool,
gpointer data,
GError **error);
Inserts data
into the list of tasks to be executed by pool
.
When the number of currently running threads is lower than the
maximal allowed number of threads, a new thread is started (or
reused) with the properties given to g_thread_pool_new().
Otherwise, data
stays in the queue until a thread in this pool
finishes its previous task and processes data
.
error
can be NULL to ignore errors, or non-NULL to report
errors. An error can only occur when a new thread couldn't be
created. In that case data
is simply appended to the queue of
work to do.
Before version 2.32, this function did not return a success status.
Returns
TRUE on success, FALSE if an error occurred
g_thread_pool_set_max_threads ()
gboolean
g_thread_pool_set_max_threads (GThreadPool *pool,
gint max_threads,
GError **error);
Sets the maximal allowed number of threads for pool
.
A value of -1 means that the maximal number of threads
is unlimited. If pool
is an exclusive thread pool, setting
the maximal number of threads to -1 is not allowed.
Setting max_threads
to 0 means stopping all work for pool
.
It is effectively frozen until max_threads
is set to a non-zero
value again.
A thread is never terminated while calling func
, as supplied by
g_thread_pool_new(). Instead the maximal number of threads only
has effect for the allocation of new threads in g_thread_pool_push().
A new thread is allocated, whenever the number of currently
running threads in pool
is smaller than the maximal number.
error
can be NULL to ignore errors, or non-NULL to report
errors. An error can only occur when a new thread couldn't be
created.
Before version 2.32, this function did not return a success status.
Returns
TRUE on success, FALSE if an error occurred
g_thread_pool_get_max_threads ()
gint
g_thread_pool_get_max_threads (GThreadPool *pool);
Returns the maximal number of threads for pool
.
Returns
the maximal number of threads
g_thread_pool_get_num_threads ()
guint
g_thread_pool_get_num_threads (GThreadPool *pool);
Returns the number of threads currently running in pool
.
Returns
the number of threads currently running
g_thread_pool_unprocessed ()
guint
g_thread_pool_unprocessed (GThreadPool *pool);
Returns the number of tasks still unprocessed in pool
.
Returns
the number of unprocessed tasks
g_thread_pool_free ()
void
g_thread_pool_free (GThreadPool *pool,
gboolean immediate,
gboolean wait_);
Frees all resources allocated for pool
.
If immediate
is TRUE, no new task is processed for pool
.
Otherwise pool
is not freed before the last task is processed.
Note however, that no thread of this pool is interrupted while
processing a task. Instead at least all still running threads
can finish their tasks before the pool
is freed.
If wait_
is TRUE, the functions does not return before all
tasks to be processed (dependent on immediate
, whether all
or only the currently running) are ready.
Otherwise the function returns immediately.
After calling this function pool
must not be used anymore.
g_thread_pool_set_max_unused_threads ()
void
g_thread_pool_set_max_unused_threads (gint max_threads);
Sets the maximal number of unused threads to max_threads
.
If max_threads
is -1, no limit is imposed on the number
of unused threads.
The default value is 2.
g_thread_pool_get_max_unused_threads ()
gint
g_thread_pool_get_max_unused_threads (void);
Returns the maximal allowed number of unused threads.
Returns
the maximal number of unused threads
g_thread_pool_get_num_unused_threads ()
guint
g_thread_pool_get_num_unused_threads (void);
Returns the number of currently unused threads.
Returns
the number of currently unused threads
g_thread_pool_stop_unused_threads ()
void
g_thread_pool_stop_unused_threads (void);
Stops all currently unused threads. This does not change the
maximal number of unused threads. This function can be used to
regularly stop all unused threads e.g. from g_timeout_add().
g_thread_pool_set_sort_function ()
void
g_thread_pool_set_sort_function (GThreadPool *pool,
GCompareDataFunc func,
gpointer user_data);
Sets the function used to sort the list of tasks. This allows the
tasks to be processed by a priority determined by func
, and not
just in the order in which they were added to the pool.
Note, if the maximum number of threads is more than 1, the order
that threads are executed cannot be guaranteed 100%. Threads are
scheduled by the operating system and are executed at random. It
cannot be assumed that threads are executed in the order they are
created.
Since: 2.10
g_thread_pool_set_max_idle_time ()
void
g_thread_pool_set_max_idle_time (guint interval);
This function will set the maximum interval
that a thread
waiting in the pool for new tasks can be idle for before
being stopped. This function is similar to calling
g_thread_pool_stop_unused_threads() on a regular timeout,
except this is done on a per thread basis.
By setting interval
to 0, idle threads will not be stopped.
The default value is 15000 (15 seconds).
Since: 2.10
g_thread_pool_get_max_idle_time ()
guint
g_thread_pool_get_max_idle_time (void);
This function will return the maximum interval
that a
thread will wait in the thread pool for new tasks before
being stopped.
If this function returns 0, threads waiting in the thread
pool for new work are not stopped.
Returns
the maximum interval
(milliseconds) to wait
for new tasks in the thread pool before stopping the
thread
Since: 2.10
g_thread_pool_move_to_front ()
gboolean
g_thread_pool_move_to_front (GThreadPool *pool,
gpointer data);
Moves the item to the front of the queue of unprocessed
items, so that it will be processed next.
Returns
TRUE if the item was found and moved
Since: 2.46