#include <pthread.h>
Go to the source code of this file.
Classes | |
struct | queue_elblock_struct |
struct | queue_struct |
#define | ELEMENT_BLOCKSIZE 64 |
#define | MAX_QUEUENAME_LENGTH 32 |
typedef struct queue_elblock_struct | queue_elblock_t |
typedef struct queue_struct | queue_t |
queue_t * | create_queue (const char *name) |
int | enqueue_element_signal (queue_t *queuehead, void *element) |
int | enqueue_element_expedited_signal (queue_t *queuehead, void *element, int exp) |
void * | dequeue_element_wait (queue_t *queuehead) |
void * | dequeue_element_timedwait (queue_t *queuehead, const struct timespec *tspec) |
int | destroy_queue (queue_t *queuehead) |
void * | dequeue_element_nonblocking (queue_t *queuehead) |
unsigned long | queue_nr_of_elements (queue_t *queue) |
int | queue_is_expedited_enabled (queue_t *queue) |
int | queue_enable_expedited (queue_t *queue, int exp) |
Fast and thread-safe queue to send/receive messages between POSIX threads ----------------------------------------------------------
Fast and thread-safe queue to send/receive messages between POSIX threads This can be used as a port for a thread to receive messages (from any thread). The implementations allows for arbitrary long queues, but queues grow by element blocks containing ELEMENT_BLOCKSIZE elements. This avoids frequent malloc/free operations.
Definition in file fastqueue.h.
#define ELEMENT_BLOCKSIZE 64 |
Definition at line 48 of file fastqueue.h.
Referenced by dequeue_element_nonblocking(), dequeue_element_timedwait(), dequeue_element_wait(), and enqueue_element_expedited_signal().
#define MAX_QUEUENAME_LENGTH 32 |
typedef struct queue_elblock_struct queue_elblock_t |
typedef struct queue_struct queue_t |