src/queue.h

   1 #ifndef _QUEUE_H_
   2 #define _QUEUE_H_
   3
   4 #include <pthread.h>
   5 #include "list.h"
   6
   7 typedef struct
   8 {
   9         List list;
  10         pthread_mutex_t mtx;
  11 } Queue;
  12
  13 Queue *queue_create();
  14 void queue_delete(Queue *queue);
  15 void queue_enqueue(Queue *queue, void *elem);
  16 void *queue_dequeue(Queue *queue);
  17 void *queue_dequeue_callback(Queue *queue, void (*callback)(void *elem));
  18
  19 #endif