| #ifndef QUEUE_H | |
| #define QUEUE_H | |
| #include <pthread.h> | |
| struct queue { | |
| int head, tail; | |
| void ** data; | |
| int size; | |
| int prod_threads; // no of producing threads | |
| int end_count; | |
| pthread_mutex_t mutex; | |
| pthread_cond_t empty, full; | |
| }; | |
| void queue_signal_terminate(struct queue * que); | |
| void queue_init(struct queue* que, int size, int prod_threads); | |
| void queue_destroy(struct queue* que); | |
| int dequeue(struct queue* que, void** to_buf); | |
| void enqueue(struct queue* que, void* from_buf); | |
| #endif //QUEUE |