Vala.Concurrent.ThreadPool – Valacore

Description:

public class ThreadPool : Object

Generic fixed-size thread pool for asynchronous task execution.

ThreadPool executes submitted tasks on worker threads and returns Future values for result-oriented workflows.

Package: Valacore

Content:

Static methods:

public static ThreadPool global ()

Returns process-wide shared thread pool.

public static void go (owned VoidTaskFunc task)

Executes a fire-and-forget task on the global pool.

public static Result<ThreadPool,Error> of (int poolSize)

Creates a fixed-size thread pool.

public static ThreadPool withDefault ()

Creates a thread pool sized to current CPU core count.

Methods:

public int activeCount ()

Returns currently executing task count.

public bool awaitTermination (Duration timeout)

Waits for worker termination up to timeout.

public void execute (owned VoidTaskFunc task)

Submits a task without return value.

public ArrayList<Future<T>> invokeAll<T> (ArrayList<ThreadPoolTaskFunc<T>> tasks)

Submits all tasks and returns futures in the same order.

public bool isShutdown ()

Returns whether shutdown has been requested.

public int queueSize ()

Returns queued task count.

public void shutdown ()

Shuts down the pool after queued tasks are processed.

public void shutdownNow ()

Requests immediate shutdown.

public Future<T> submit<T> (owned TaskFunc<T> task)

Submits a task and returns a future for its result.

Inherited Members:

All known members inherited from class GLib.Object

ThreadPool