RingQueue

Undocumented in source.

struct RingQueue (

T

Event

) {

size_t length;

size_t fetch;

size_t insert;

size_t refCount;

AlignedSpinLock lock;

this(size_t capacity, Event cts, Event rtr);

void push(T ctx);

bool tryPop(T output);

bool readyToRead();

bool empty();

void close();

void retain();

bool release();

}

Constructors

this this(size_t capacity, Event cts, Event rtr): Undocumented in source.

Members

Functions

close void close(): Undocumented in source. Be warned that the author may not have intended to support it.
empty bool empty(): Undocumented in source. Be warned that the author may not have intended to support it.
push void push(T ctx): Undocumented in source. Be warned that the author may not have intended to support it.
readyToRead bool readyToRead(): Undocumented in source. Be warned that the author may not have intended to support it.
release bool release(): Undocumented in source. Be warned that the author may not have intended to support it.
retain void retain(): Undocumented in source. Be warned that the author may not have intended to support it.
tryPop bool tryPop(T output): Undocumented in source. Be warned that the author may not have intended to support it.

Variables

closed bool closed;: Undocumented in source.
cts Event cts;: Undocumented in source.
fetch size_t fetch;
insert size_t insert;: Undocumented in source.
length size_t length;: Undocumented in source.
lock AlignedSpinLock lock;: Undocumented in source.
refCount size_t refCount;
rtr Event rtr;
size size_t size;: Undocumented in source.
store T* store;: Undocumented in source.

Meta

Source

See Implementation

photon ds ring_queue functions

structs

RingQueue