Start unlocked with zero elements in the fast path

Delete the task using its proper type

Movable but not copyable

Movable but not copyable

Movable but not copyable

Finish the task after it has been executed and the result set

Wait for a task to complete (for threads outside thread pool)

Get the result of the task

Get the result of the task

Get the exception associated with a canceled task

Get the task linked to this event. This can only be called once.

In order to ensure the UI is always responsive, you can disallow blocking calls in the UI thread. Note that the wait handler isn't called when the res

Interruption point, throws task_canceled if the specified token is set.

Thread which increments the label value every ms

Constructor, used by local_spawn

Use aligned memory allocation

Copy the completed task object to the shared state. The event is automatically signaled when all references are dropped.

Copy the completed task object to the shared state. The event is automatically signaled when all references are dropped.

Simply tell the state that our task has finished, it already has a copy of the task object.

Pop a task from the bottom of this thread's queue

Push a task to the bottom of this thread's queue

Check whether the task is ready and include an acquire barrier if it is

Query whether the task has finished executing

Check if the task has finished executing

Recursive function to spawn all worker threads in parallel

By default the reference count is initialized to 1

Note that this doesn't increment the reference count, instead it takes ownership of a pointer which you already own a reference to.

Run the task but run the given wait handler when waiting for a task, instead of just sleeping.

Schedule a continuation task using its scheduler

Thread scheduler implementation

Schedule a task on the thread pool

Convert a task to void* and send it to the gtk main loop

Set the result of the task, mark it as completed and run its continuations