message_queue.h

Go to the documentation of this file.

#ifndef CVD_INCLUDE_MESSAGE_QUEUE_H
#define CVD_INCLUDE_MESSAGE_QUEUE_H

#include <cvd/synchronized.h>
#include <semaphore.h>
#include <deque>

namespace CVD
{

template<class C> class MessageQueue
{
        public:
                MessageQueue()
                {
                        sem_init(&empty_slots, 0, 0);
                }

                ~MessageQueue()
                {
                        sem_destroy(&empty_slots);
                }

                void write(const C& message)
                {       
                        //Lock the queue, so it can be safely used.
                        queue_mutex.lock();
                        queue.push_back(message);
                        queue_mutex.unlock();

                        sem_post(&empty_slots);
                }
                
                C read()
                {
                        sem_wait(&empty_slots);
                        C ret;

                        queue_mutex.lock();
                        ret = queue.front();
                        queue.pop_front();
                        queue_mutex.unlock();

                        return ret;
                }

                int size()
                {
                        int s;
                        sem_getvalue(&empty_slots, &s);
                        return s;
                }

        private:
                Synchronized queue_mutex;
                std::deque<C> queue;
                sem_t empty_slots;
};

}
#endif

---

libcvd
Author(s): Edward Rosten, Paul Smith, Tom Drummond, Gerhard Reitmayr, Ethan Eade, Timothy Gan, Chris Kemp, Georg Klein
autogenerated on Fri Jan 11 09:13:10 2013