fearless.concurrency

Safe concurrency based on std.concurrency.

Members

Functions

receive
void receive(T ops)
Undocumented in source. Be warned that the author may not have intended to support it.
receiveOnly
auto receiveOnly()
Undocumented in source. Be warned that the author may not have intended to support it.
send
void send(Tid tid, A args)

Wraps std.concurrency.send to make sure it's not possible to send a fearless.sharing.Exclusive that is already locked to another thread.

spawn
auto spawn(F fn, A args)
Undocumented in source. Be warned that the author may not have intended to support it.

Imports

Tid (from std.concurrency)
public import std.concurrency : Tid, thisTid;
Undocumented in source.
thisTid (from std.concurrency)
public import std.concurrency : Tid, thisTid;
Undocumented in source.

Meta