AtomicQueue

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

Constructors

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

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.

Inherited Members

From Boxed

cInstancePtr
void* cInstancePtr;

Pointer to the C boxed value

getType
GType getType()

Get the GType of this boxed type.

gType
GType gType [@property getter]

Boxed GType property.

self
Boxed self()

Convenience method to return this cast to a type. For use in D with statements.

copy_
void* copy_()

Make a copy of the wrapped C boxed data.

boxedCopy
void* boxedCopy(void* cBoxed)

Copy a C boxed value using g_boxed_copy.

boxedFree
void boxedFree(void* cBoxed)

Free a C boxed value using g_boxed_free.