Lines Matching refs:queue
22 tq_listTp first; /* first element in the queue */
23 tq_listTp last; /* last element in the queue */
24 pthread_mutex_t lock; /* queue mutex */
25 pthread_cond_t cond; /* queue condition to signal new elements */
28 int stopping; /* queue is currently stopping */
29 int queue_size; /* current size of the queue */
30 int nb_thr; /* current nb of threads pocessing the queue */
32 int max_thr; /* max allowed threads to process the queue */
34 PFP doit; /* function to call to process the queue */
40 extern tqTp tq_alloc(PFP process_func, /* function to process the queue */
47 extern int tq_queue(tqTp queue, /* pointer to the queue */
51 extern void * tq_dequeue(tqTp queue, /* pointer to the queue */
57 extern void tq_end_thread (tqTp queue, /* pointer to the queue */
61 * tq_shutdown, shutdown the queue (alternate way to shutdown if you don't
65 * in the queue (immadiate = 0)
70 * when tq_dequeue returns, the queue pointer is not allocated anymore
73 extern void tq_shutdown(tqTp queue, /* pointer to the queue */
74 int immediate); /* 1: don't wait, 0: wait for queue */