ManualEvent

A manually triggered multi threaded cross-task event.

Note: the ownership can be shared between multiple fibers and threads.

struct ManualEvent {

import core.thread : Thread;;

template Waitable(CB, alias WAIT, alias CANCEL, alias DONE) via import vibe.internal.async : Waitable, asyncAwait, asyncAwaitUninterruptible, asyncAwaitAny;;

auto asyncAwait(Duration timeout, string func) via import vibe.internal.async : Waitable, asyncAwait, asyncAwaitUninterruptible, asyncAwaitAny;;

auto asyncAwaitUninterruptible(Duration timeout, string func) via import vibe.internal.async : Waitable, asyncAwait, asyncAwaitUninterruptible, asyncAwaitAny;;

void asyncAwaitAny(string func) via import vibe.internal.async : Waitable, asyncAwait, asyncAwaitUninterruptible, asyncAwaitAny;;

struct StackSList(T) via import vibe.internal.list : StackSList;;

package @safe static

EventID ms_threadEvent;

bool opCast();

int emitCount();

int emitSingle();

int wait(int emit_count);

int wait(Duration timeout, int emit_count);

int waitUninterruptible();

int waitUninterruptible(int emit_count);

int waitUninterruptible(Duration timeout, int emit_count);

}

Postblit

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

Members

Enums

EmitMode enum EmitMode: Undocumented in source.

Functions

emit int emit(): Emits the signal, waking up all owners of the signal.
emitCount int emitCount(): A counter that is increased with every emit() call
emitSingle int emitSingle(): Emits the signal, waking up at least one waiting task
opCast deprecated bool opCast(): Undocumented in source. Be warned that the author may not have intended to support it.
wait int wait(): Acquires ownership and waits until the signal is emitted.
wait int wait(int emit_count)
int wait(Duration timeout, int emit_count): Acquires ownership and waits until the emit count differs from the given one or until a timeout is reached.
waitUninterruptible int waitUninterruptible()
int waitUninterruptible(int emit_count)
int waitUninterruptible(Duration timeout, int emit_count): Same as wait, but defers throwing any InterruptException.

Static variables

ms_threadEvent EventID ms_threadEvent;: Undocumented in source.

Meta

Source

See Implementation