gst.atomic_queue

Module for [AtomicQueue] class

class AtomicQueue

Types 1

classAtomicQueue : gobject.boxed.Boxed

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

Methods
void * _cPtr(Flag!"Dup" dup = No.Dup)
GType _getGType()
GType _gType() @property
AtomicQueue self()Returns `this`, for use in `with` statements.
uint length()Get the amount of items in the queue. Returns: the number of elements in the queue.
void * peek()Peek the head element of the queue without removing it from the queue. Returns: the head element of queue or null when the queue is empty.
void * pop()Get the head element of the queue. Returns: the head element of queue or null when the queue is empty.
void push(void * data = null)Append data to the tail of the queue.
Constructors
this(void * ptr, Flag!"Take" take)
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.