Queue.h

Go to the documentation of this file.

#ifndef QUEUE_H
#define QUEUE_H

#include <pthread.h>
#include "stdinc.h"
#include "Util.h"

namespace forest {


class Queue {
public:                         Queue(int=10);
                                ~Queue();
                bool            init();
                void            reset();

                bool            empty() const;

                void            enq(int);
                int             deq();          
                int             deq(uint32_t);  
                static          int const TIMEOUT = (1 << 31); // largest 32 bit negative number
private:
                int             qMax;                                           

                int             count;                                          
                int             head;                                           
                int             tail;                                           

                int             *buf;                                           

                pthread_mutex_t lock;                           
                pthread_cond_t emptyQ;                          
                pthread_cond_t fullQ;                           
};

inline bool Queue::empty() const { return count == 0; }

} // ends namespace


#endif