jin.go.queue

Constructors

this

this(size_t size)

Ring buffer of transferring messages.

Members

Functions

available

ptrdiff_t available()

Count of messages to fulfill buffer. Negative value - new messages will never provided.

empty

auto empty()

True when no more messages can never be consumed.

front

Message front()

Get current pending message. pending must be checked before.

ignore

bool ignore()

True when no more messages can never be provided.

pending

ptrdiff_t pending()

Count of provided messages. Negative value - new messages will never provided.

popFront

void popFront()

Consume current pending message. pending must be checked before.

put

void put(Value value)

Put message without locking. available must be checked before.

put

void put(Args args)

Create and put message. available must be checked before.

Properties

size

size_t size [@property getter]

Maximum count of transferring messages.

Variables

consumer

Cursor consumer;

Cursor to next free slot for message.

• await
• channel
• cursor
• go
• input
• mem
• output
• queue