queue.c

#include "queue.h"

Queue *queueInit(int size) {
    Queue *q;

    q = (Queue *)malloc(sizeof(Queue));
    if (q == NULL)
        return NULL;

    q->size = size;
    q->buf = (WorkFunction *)malloc(q->size * sizeof(WorkFunction));
    q->empty = 1;
    q->full = 0;
    q->head = 0;
    q->tail = 0;
    q->mut = (pthread_mutex_t *)malloc(sizeof(pthread_mutex_t));
    pthread_mutex_init(q->mut, NULL);
    q->notFull = (pthread_cond_t *)malloc(sizeof(pthread_cond_t));
    pthread_cond_init(q->notFull, NULL);
    q->notEmpty = (pthread_cond_t *)malloc(sizeof(pthread_cond_t));
    pthread_cond_init(q->notEmpty, NULL);

    return q;
}

void queueDelete(Queue *q) {
    pthread_mutex_destroy (q->mut);
    free (q->mut);
    pthread_cond_destroy (q->notFull);
    free (q->notFull);
    pthread_cond_destroy (q->notEmpty);
    free (q->notEmpty);

    free (q);
}

void queueAdd(Queue *q, WorkFunction in) {
    q->buf[q->tail] = in;
    q->tail++;
    if (q->tail == q->size)
        q->tail = 0;
    if (q->tail == q->head)
        q->full = 1;
    q->empty = 0;
}

void queueDel(Queue *q, WorkFunction *out) {
    *out = q->buf[q->head];

    q->head++;
    if (q->head == q->size)
        q->head = 0;
    if (q->head == q->tail)
        q->empty = 1;
    q->full = 0;
}