WaitableQueue

Undocumented in source.

final

class WaitableQueue (

Q

) {

import core.sync.semaphore : Semaphore;;

import core.time : Duration;;

import mir.algebraic : Nullable;;

bool push(Q.ElementType t);

Q.ElementType pop();

bool empty();

Q.ElementType pop(Duration max);

static if(__traits(compiles, q.producer))

shared(WaitableQueueProducer!Q) producer();

}

Constructors

this this(): Undocumented in source.

Members

Functions

empty bool empty(): Undocumented in source. Be warned that the author may not have intended to support it.
pop Q.ElementType pop(Duration max): Undocumented in source. Be warned that the author may not have intended to support it.
pop Q.ElementType pop(): Undocumented in source. Be warned that the author may not have intended to support it.
producer shared(WaitableQueueProducer!Q) producer(): Undocumented in source. Be warned that the author may not have intended to support it.
push bool push(Q.ElementType t): Undocumented in source. Be warned that the author may not have intended to support it.

Meta

Source

See Implementation

concurrency data queue waitable classes

WaitableQueue

structs

WaitableQueueProducer