LocalThreadWorker

Undocumented in source.

package package

struct LocalThreadWorker {

import core.time : Duration, msecs, hnsecs;;

import core.time : Duration, msecs, hnsecs;;

import core.time : Duration, msecs, hnsecs;;

struct Timer via import concurrency.scheduler : Timer, TimerTrigger, TimerDelegate;;

enum TimerTrigger via import concurrency.scheduler : Timer, TimerTrigger, TimerDelegate;;

alias TimerDelegate = void delegate(TimerTrigger) shared @(safe) via import concurrency.scheduler : Timer, TimerTrigger, TimerDelegate;;

this(LocalThreadExecutor e);

void start();

void schedule(VoidDelegate dg);

Timer addTimer(TimerDelegate dg, Duration dur);

void cancelTimer(Timer timer);

bool isInContext();

}

Constructors

this this(LocalThreadExecutor e): Undocumented in source.

Members

Functions

addTimer Timer addTimer(TimerDelegate dg, Duration dur): Undocumented in source. Be warned that the author may not have intended to support it.
cancelTimer void cancelTimer(Timer timer): Undocumented in source. Be warned that the author may not have intended to support it.
isInContext bool isInContext(): Undocumented in source. Be warned that the author may not have intended to support it.
schedule void schedule(VoidDelegate dg): Undocumented in source. Be warned that the author may not have intended to support it.
start void start(): Undocumented in source. Be warned that the author may not have intended to support it.
stop void stop(): Undocumented in source. Be warned that the author may not have intended to support it.

Meta

Source

See Implementation

concurrency thread classes

functions

structs