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.

package final

class TaskFiber : Fiber {

import std.concurrency : Tid, thisTid;;

import std.concurrency : Tid, thisTid;;

static if((void*).sizeof >= 8)

enum defaultTaskStackSize;

static if(!((void*).sizeof >= 8))

enum defaultTaskStackSize;

int m_yieldLockCount;

TaskFuncInfo m_taskFunc;

package __gshared

size_t ms_taskStackSize;

package __gshared

TaskEventCallback ms_taskEventCallback;

package __gshared

TaskCreationCallback ms_taskCreationCallback;

debug(VibeRunningTasks)

string[TaskFiber] s_runningTasks;

static TaskFiber getThis();

static if(!__traits(compiles, () @(safe)()))

State state [@property getter];

inout(Thread) thread [@property getter];

Task task [@property getter];

inout(ThreadInfo) tidInfo [@property getter];

void shutdown();

void join(size_t task_counter);

void interrupt(size_t task_counter);

void bumpTaskCounter();

void handleInterrupt(void delegate() @(safe) nothrow on_interrupt);

void handleInterrupt();

}

Constructors

this this(): Undocumented in source.

Members

Functions

bumpTaskCounter void bumpTaskCounter(): Sets the fiber to initialized state and increments the task counter.
handleInterrupt void handleInterrupt(void delegate() @(safe) nothrow on_interrupt): Undocumented in source. Be warned that the author may not have intended to support it.
handleInterrupt void handleInterrupt(): Undocumented in source. Be warned that the author may not have intended to support it.
interrupt void interrupt(size_t task_counter): Throws an InterruptExeption within the task as soon as it calls an interruptible function.
join void join(size_t task_counter): Blocks until the task has ended.
shutdown void shutdown(): Shuts down the task handler loop.

Manifest constants

defaultTaskStackSize enum defaultTaskStackSize;: Undocumented in source.
defaultTaskStackSize enum defaultTaskStackSize;: Undocumented in source.

Properties

state State state [@property getter]: Undocumented in source. Be warned that the author may not have intended to support it.
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.

Static functions

getThis TaskFiber getThis(): Undocumented in source. Be warned that the author may not have intended to support it.

Static variables

ms_taskCreationCallback TaskCreationCallback ms_taskCreationCallback;: Undocumented in source.
ms_taskEventCallback TaskEventCallback ms_taskEventCallback;: Undocumented in source.
ms_taskStackSize size_t ms_taskStackSize;: Undocumented in source.
s_runningTasks string[TaskFiber] s_runningTasks;: Undocumented in source.

Variables

m_taskFunc TaskFuncInfo m_taskFunc;: Undocumented in source.
m_yieldLockCount int m_yieldLockCount;: Undocumented in source.

Meta

Source

See Implementation

vibe core task aliases

classes

enums

functions

callWithMove

manifest constants

maxTaskParameterSize

structs