bounded_queue.h

Go to the documentation of this file.

#ifndef QUEUE_H
#define QUEUE_H
 
#include <stdlib.h>
#include <stddef.h>
#include <pthread.h>

typedef struct {
    void **buf; /* ring of capacity slots*/
    size_t capacity;
    size_t head; /* next slot to pop from*/
    size_t tail; /* next slot to push into*/
    size_t count; /* current occupancy */
 
    pthread_mutex_t mu_lock;
    pthread_cond_t not_empty; /*A conditional signal when queue is empty, blocks/frees consumers*/
    pthread_cond_t not_full; /*A conditional signal when queue is full, blocks/frees producers*/
 
    int done; /*Shutdown flag*/
} bounded_queue_t;

bounded_queue_t *bq_create(size_t capacity);

void bq_destroy(bounded_queue_t *q);

int bq_push(bounded_queue_t *q, void *item);    

void *bq_pop(bounded_queue_t *q);                

void bq_shutdown(bounded_queue_t *q);            
#endif