mecca.reactor

Define the micro-threading reactor

Modules

fiber_group module mecca.reactor.fiber_group: group related fibers so they can all be killed together, if needed
fiber_poool module mecca.reactor.fiber_poool: Undocumented in source.
fls module mecca.reactor.fls: Fiber local storage
impl module mecca.reactor.impl
io module mecca.reactor.io
lib module mecca.reactor.lib
platform module mecca.reactor.platform: Undocumented in source.
subsystems module mecca.reactor.subsystems
sync module mecca.reactor.sync
tests module mecca.reactor.tests
types module mecca.reactor.types: Type definitions for reactor related types
utils module mecca.reactor.utils: Assorted helpers

Public Imports

mecca.reactor.types public import mecca.reactor.types;: Undocumented in source.

Members

Aliases

FiberIncarnation alias FiberIncarnation = ushort: Undocumented in source.
TimerHandle alias TimerHandle = Reactor.TimerHandle: Handle for manipulating registered timers.

Enums

FiberState enum FiberState: Track the fiber's state

Functions

testWithReactor int testWithReactor(int delegate() dg, Reactor.OpenOptions options)
void testWithReactor(void delegate() dg, Reactor.OpenOptions options): Run a test inside a reactor
to ReactorFiber* to(FiberIdx fidx): Undocumented in source. Be warned that the author may not have intended to support it.
to FiberIdx to(ReactorFiber* rfp): Undocumented in source. Be warned that the author may not have intended to support it.
to FiberIdx to(FiberId fiberId): Undocumented in source. Be warned that the author may not have intended to support it.

Mixin templates

TEST_FIXTURE_REACTOR mixintemplate TEST_FIXTURE_REACTOR(FIXTURE): Undocumented in source.

Properties

isReactorThread bool isReactorThread [@property getter]: Returns whether the current thread is the thread in which theReactor is running
theReactor Reactor theReactor [@property getter]: return a reference to the Reactor singleton

Structs

FiberHandle struct FiberHandle: A handle to a running fiber.
Reactor struct Reactor: The main scheduler for the micro-threading architecture.
ReactorFiber struct ReactorFiber: Undocumented in source.
mecca_ut (from mecca.runtime.ut) struct mecca_ut via public import mecca.runtime.ut : mecca_ut;: Undocumented in source.

Meta

Source

See Source File

mecca modules