Queue

Multiple producer, "single" consumer thread safe queue.

The value may be T.init if multiple consumers try to pop a value at the same time.

struct Queue (

RawT

) {

import std.container.dlist : DList;;

static if(is(RawT == U*, U))

enum AsPointer;

alias T = RawT;

static if(!(is(RawT == U*, U)))

enum AsPointer;

struct Item(TT);

this(Mutex mtx);

static if(AsPointer)

bool put(T* a);

static if(!(AsPointer))

bool put(T a);

alias PopReturnType = Item!(T*);

Item!(T*) pop();

bool empty();

size_t length();

void teardown(void delegate(ref T) deinit);

}

Constructors

this this(Mutex mtx): Undocumented in source.

Postblit

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

Members

Aliases

PopReturnType alias PopReturnType = Item!(T*): Undocumented in source.
T alias T = U: Undocumented in source.
T alias T = RawT: Undocumented in source.

Functions

empty bool empty(): Undocumented in source. Be warned that the author may not have intended to support it.
length size_t length(): Undocumented in source. Be warned that the author may not have intended to support it.
pop Item!(T*) pop(): Undocumented in source. Be warned that the author may not have intended to support it.
put bool put(T* a): Undocumented in source. Be warned that the author may not have intended to support it.
put bool put(T a): Undocumented in source. Be warned that the author may not have intended to support it.
teardown void teardown(void delegate(ref T) deinit): clear the queue and permanently shut it down by rejecting put messages.

Manifest constants

AsPointer enum AsPointer;: Undocumented in source.
AsPointer enum AsPointer;: Undocumented in source.

Structs

Item struct Item(TT): Undocumented in source.

Meta

Source

See Implementation

my actor common enums

functions

makeSignature

structs

Queue