AtomicQueue

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

Constructors

this
this(GstAtomicQueue* gstAtomicQueue, bool ownedRef)

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.

Destructor

~this
~this()
Undocumented in source.

Members

Functions

doref
void doref()

Increase the refcount of @queue.

getAtomicQueueStruct
GstAtomicQueue* getAtomicQueueStruct(bool transferOwnership)

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.

Static functions

getType
GType getType()

Variables

gstAtomicQueue
GstAtomicQueue* gstAtomicQueue;

the main Gtk struct

ownedRef
bool ownedRef;
Undocumented in source.

Meta