semaphore.h

Go to the documentation of this file.

#ifndef MY_SEMAPHORE_H_
#define MY_SEMAPHORE_H_

#include <iostream>
#include <boost/thread.hpp>

namespace micros_swarm{
    class Semaphore{
        public:
            Semaphore(int value): value_(value){}
            Semaphore(const Semaphore&) = delete;

            void P()
            {
                boost::unique_lock<boost::mutex> lock(mutex_);
                while(value_ == 0) {
                    condition_.wait(lock);
                }

                value_--;
            }

            void V()
            {
                boost::unique_lock<boost::mutex> lock(mutex_);
                value_++;

                condition_.notify_one();
            }
        private:
            int value_;
            boost::mutex mutex_;
            boost::condition_variable condition_;
    };
};

#endif