Lines Matching defs:queue
22 * @brief Thread Safe FIFO bounded queue
23 * @note Since most implementations of the queue are backed by a condition
39 * @defgroup APR_Util_FIFO Thread Safe FIFO bounded queue
50 * create a FIFO queue
51 * @param queue The new queue
52 * @param queue_capacity maximum size of the queue
53 * @param a pool to allocate queue from
55 APU_DECLARE(apr_status_t) apr_queue_create(apr_queue_t **queue,
60 * push/add an object to the queue, blocking if the queue is already full
62 * @param queue the queue
65 * @returns APR_EOF the queue has been terminated
68 APU_DECLARE(apr_status_t) apr_queue_push(apr_queue_t *queue, void *data);
71 * pop/get an object from the queue, blocking if the queue is already empty
73 * @param queue the queue
76 * @returns APR_EOF if the queue has been terminated
79 APU_DECLARE(apr_status_t) apr_queue_pop(apr_queue_t *queue, void **data);
82 * push/add an object to the queue, returning immediately if the queue is full
84 * @param queue the queue
87 * @returns APR_EAGAIN the queue is full
88 * @returns APR_EOF the queue has been terminated
91 APU_DECLARE(apr_status_t) apr_queue_trypush(apr_queue_t *queue, void *data);
94 * pop/get an object to the queue, returning immediately if the queue is empty
96 * @param queue the queue
99 * @returns APR_EAGAIN the queue is empty
100 * @returns APR_EOF the queue has been terminated
103 APU_DECLARE(apr_status_t) apr_queue_trypop(apr_queue_t *queue, void **data);
106 * returns the size of the queue.
109 * of the queue.
110 * @param queue the queue
111 * @returns the size of the queue
113 APU_DECLARE(unsigned int) apr_queue_size(apr_queue_t *queue);
116 * interrupt all the threads blocking on this queue.
118 * @param queue the queue
120 APU_DECLARE(apr_status_t) apr_queue_interrupt_all(apr_queue_t *queue);
123 * terminate the queue, sending an interrupt to all the
126 * @param queue the queue
128 APU_DECLARE(apr_status_t) apr_queue_term(apr_queue_t *queue);