WorkerPool

Object Hierarchy:

Description:

    var pool = WorkerPool.withDefault ();
    pool.execute (() => {
        // background work
    });
    pool.shutdown ();

    var created = WorkerPool.of (4);
    if (created.isError ()) {
        return;
    }
    var pool = created.unwrap ();
    int result = pool.submitInt (() => { return 42; }).await ();
    pool.shutdown ();

Content:

Static methods:

• public static Result<WorkerPool,Error> of (int poolSize)
  Creates a thread pool with the specified number of worker threads.
• public static WorkerPool withDefault ()
  Creates a thread pool with pool size equal to the number of CPU cores.

Methods:

• public int activeCount ()
  Returns the number of currently active (executing) tasks.
• public void execute (owned VoidTaskFunc task)
  Executes a void task in the thread pool.
• public bool isShutdown ()
  Returns whether the pool has been shut down.
• public int poolSize ()
  Returns the number of worker threads in this pool.
• public int queueSize ()
  Returns the number of tasks waiting in the queue.
• public void shutdown ()
  Signals shutdown and waits for all queued tasks to complete. No new tasks can be submitted after calling this method.
• public PromiseBool submitBool (owned TaskFunc<bool> task)
  Submits a task that returns a bool and returns a PromiseBool representing the pending result.
• public PromiseDouble submitDouble (owned TaskFunc<double?> task)
  Submits a task that returns a double and returns a PromiseDouble representing the pending result.
• public PromiseInt submitInt (owned TaskFunc<int> task)
  Submits a task that returns an int and returns a PromiseInt representing the pending result.
• public PromiseString submitString (owned TaskFunc<string> task)
  Submits a task that returns a string and returns a PromiseString representing the pending result.

Inherited Members: