AtomicQueue

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

class AtomicQueue : Boxed {

this(uint initialSize);

uint length();

void* peek();

void push(void* data);

}

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.

gst atomic_queue classes

AtomicQueue