vl_async_queue.h

Go to the documentation of this file.

 
#ifndef VL_ASYNC_QUEUE_H
#define VL_ASYNC_QUEUE_H
 
#include "vl_async_pool.h"
#include "vl_atomic.h"
#include "vl_atomic_ptr.h"
 
typedef struct
{
    vl_async_pool elements;
 
    vl_atomic_ptr head;
 
    vl_atomic_ptr tail;
 
    vl_atomic_uint32_t size;
 
    vl_uint16_t elementSize;
} vl_async_queue;
 
VL_API void vlAsyncQueueInit(vl_async_queue* queue, vl_uint16_t elementSize);
 
VL_API void vlAsyncQueueFree(vl_async_queue* queue);
 
VL_API vl_async_queue* vlAsyncQueueNew(vl_uint16_t elementSize);
 
VL_API void vlAsyncQueueDelete(vl_async_queue* queue);
 
VL_API void vlAsyncQueueClear(vl_async_queue* queue);
 
VL_API void vlAsyncQueueReset(vl_async_queue* queue);
 
VL_API void vlAsyncQueuePushBack(vl_async_queue* queue, const void* value);
 
VL_API vl_bool_t vlAsyncQueuePopFront(vl_async_queue* queue, void* result);
 
static inline vl_uint32_t vlAsyncQueueSize(const vl_async_queue* queue) { return vlAtomicLoad(&queue->size); }
 
#endif // VL_ASYNC_QUEUE_H