AtomicQueue

The GstAtomicQueue object implements a queue that can be used from multiple threads without performing any blocking operations.

Constructors

this
this(GstAtomicQueue* gstAtomicQueue)

Sets our main struct and passes it to the parent class

this
this(uint initialSize)

Create a new atomic queue instance. initial_size will be rounded up to the nearest power of 2 and used as the initial size of the queue.

Members

Functions

doref
void doref()

Increase the refcount of queue.

getAtomicQueueStruct
GstAtomicQueue* getAtomicQueueStruct()

Get the main Gtk struct

getStruct
void* getStruct()

the main Gtk struct as a void*

length
uint length()

Get the amount of items in the queue.

peek
void* peek()

Peek the head element of the queue without removing it from the queue.

pop
void* pop()

Get the head element of the queue.

push
void push(void* data)

Append data to the tail of the queue.

unref
void unref()

Unref queue and free the memory when the refcount reaches 0.

Variables

gstAtomicQueue
GstAtomicQueue* gstAtomicQueue;

the main Gtk struct

Meta