TaskFiber

The base class for a task aka Fiber.

This class represents a single task that is executed concurrently with other tasks. Each task is owned by a single thread.

class TaskFiber : Fiber {

protected shared

size_t m_taskCounter;

protected shared

bool m_running;

this(void delegate() fun, size_t stack_size);

inout(Thread) thread [@property getter];

Task task [@property getter];

inout(MessageQueue) messageQueue [@property getter];

inout(ThreadInfo) tidInfo [@property getter];

void interrupt();

void terminate();

void bumpTaskCounter();

}

Constructors

this this(void delegate() fun, size_t stack_size): Undocumented in source.

Members

Functions

bumpTaskCounter void bumpTaskCounter(): Undocumented in source. Be warned that the author may not have intended to support it.
interrupt void interrupt(): Throws an InterruptExeption within the task as soon as it calls a blocking function.
join void join(): Blocks until the task has ended.
terminate void terminate(): Terminates the task without notice as soon as it calls a blocking function.

Properties

messageQueue inout(MessageQueue) messageQueue [@property getter]: Reserved for internal use!
task Task task [@property getter]: Returns the handle of the current Task running on this fiber.
thread inout(Thread) thread [@property getter]: Returns the thread that owns this task.
tidInfo inout(ThreadInfo) tidInfo [@property getter]: Undocumented in source. Be warned that the author may not have intended to support it.

Variables

m_running bool m_running;: Undocumented in source.
m_taskCounter size_t m_taskCounter;: Undocumented in source.

Meta

Source

See Implementation

index vibe core task classes

structs

Task