FiberGroup

group of related fiber that may need to be killed together

struct FiberGroup {

class FiberGroupExtinction;

struct ExecutionResult(T);

closed [@property getter];

void close(bool waitForExit);

void waitEmpty(Timeout timeout);

bool isCurrentFiberMember();

FiberHandle spawnFiber(void delegate() dg);

FiberHandle spawnFiber(ParameterTypeTuple!F args);

FiberHandle spawnFiberIfOpen(void delegate() dg);

auto runTracked(ParameterTypeTuple!F args);

auto runTracked(T delegate() dg);

}

Destructor

~this ~this(): Undocumented in source.

Postblit

this(this) this(this): Undocumented in source.

Members

Classes

FiberGroupExtinction class FiberGroupExtinction: Undocumented in source.

Functions

close void close(bool waitForExit): close the group (killing all fibers).
isCurrentFiberMember bool isCurrentFiberMember(): Return true if the current fiber is a member of the group
open void open(): Initialize a new fiber group
runTracked auto runTracked(T delegate() dg): Perform a task inside the current fiber as part of the group.
runTracked auto runTracked(ParameterTypeTuple!F args): Perform a task inside the current fiber as part of the group.
spawnFiber FiberHandle spawnFiber(void delegate() dg)
FiberHandle spawnFiber(ParameterTypeTuple!F args): Spawn a new fiber that will be a member of the group.
spawnFiberIfOpen FiberHandle spawnFiberIfOpen(void delegate() dg): Conditionally spawn a new fiber, only if the fiber group is currently open.
waitEmpty void waitEmpty(Timeout timeout): Wait for all fibers in a group to exit.

Properties

closed closed [@property getter]: report whether a fiber group is closed

Structs

Chain struct Chain: Undocumented in source.
ExecutionResult struct ExecutionResult(T): 3state execution results type

Meta

Source

See Implementation

mecca reactor fiber_group structs

FiberGroup