AtomicQueue

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

class AtomicQueue {

GstAtomicQueue* gstAtomicQueue;

protected

bool ownedRef;

GstAtomicQueue* getAtomicQueueStruct(bool transferOwnership);

void* getStruct();

this(GstAtomicQueue* gstAtomicQueue, bool ownedRef);

static GType getType();

this(uint initialSize);

uint length();

void* peek();

void push(void* data);

void unref();

}

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

A destructor is present on this object, but not explicitly documented in the source.

Members

Functions

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.
ref_ void ref_(): Increase the refcount of 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

gstreamer AtomicQueue classes

AtomicQueue