Buffer.hpp

gehe zur Dokumentation dieser Datei

#ifndef _BUFFER_HPP
#define _BUFFER_HPP 1
#include <mutex>
#include <deque>
#include "Semaphore.hpp"
using namespace std;

template<typename ELEMENTTYPE>
class Buffer
{
private:
    deque<ELEMENTTYPE> _values;
    Semaphore * _filled;
    mutex _mu;

public:
    Buffer()
    {
        _filled = new Semaphore(0);
    }

    virtual ~Buffer()
    {
        delete _filled;
    }

    ELEMENTTYPE pop()
    {
        _filled->P(); // blockieren, wenn leer
        _mu.lock(); // start: kritischer Abschnitt -------.
            ELEMENTTYPE _return;                   //     |
            _return = _values.back();              //     |
            _values.pop_back();                    //     |
        _mu.unlock(); // ende: kritischer Abschnitt ------'
        return _return;
    }

    void push(ELEMENTTYPE ele)
    {
        _mu.lock(); // start: kritischer Abschnitt ------.
            _values.push_back(ele);               //     |
        _mu.unlock(); // ende: kritischer Abschnitt -----'
        _filled->V(); // freigeben
    }

};
#endif