AtomicQueue

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

class AtomicQueue {

GstAtomicQueue* gstAtomicQueue;

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 doref();

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

~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

Source

See Implementation

gstreamer AtomicQueue classes

AtomicQueue