queue.h

Go to the documentation of this file.

#ifndef __TQUEUE_H__
#define __TQUEUE_H__

#include <pthread.h>
#define MAX_QUEUE_ELEMENTS 10

typedef struct qelem_t qelem_t;
struct qelem_t{
  qelem_t* q_forw;
  void* data;
};

typedef struct queue_t{
  qelem_t* first; 
  qelem_t* last; 
  int nelem; 
  pthread_mutex_t mutex;
} queue_t;

int queue_init(queue_t* queue);

void queue_deinit(queue_t* queue);

int queue(queue_t* queue, void* data);

void* dequeue(queue_t* queue);

int getquenelem(queue_t* queue);

#endif