vl_async_queue.h

Go to the documentation of this file.

#ifndef VL_ASYNC_QUEUE_H
#define VL_ASYNC_QUEUE_H
 
#include "vl_atomic.h"
#include "vl_atomic_ptr.h"
#include "vl_async_pool.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;
 
void vlAsyncQueueInit(vl_async_queue* queue, vl_uint16_t elementSize);
 
void vlAsyncQueueFree(vl_async_queue* queue);
 
vl_async_queue* vlAsyncQueueNew(vl_uint16_t elementSize);
 
void vlAsyncQueueDelete(vl_async_queue* queue);
 
void vlAsyncQueueClear(vl_async_queue* queue);
 
void vlAsyncQueueReset(vl_async_queue* queue);
 
void vlAsyncQueuePushBack(vl_async_queue* queue, const void* value);
 
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