BasicEventQueue.h

Go to the documentation of this file.

#ifndef BASICEVENTQUEUE_H_39DCC18B
#define BASICEVENTQUEUE_H_39DCC18B

#include "EventQueueImpl.h"
#include <string>
#include <map>
#include <list>
#include <thread>
#include <mutex>
#include <condition_variable>

namespace uscxml {

class USCXML_API BasicEventQueue : public EventQueueImpl {
public:
    BasicEventQueue();
    virtual ~BasicEventQueue();
    virtual std::shared_ptr<EventQueueImpl> create();
    virtual Event dequeue(size_t blockMs);
    virtual void enqueue(const Event& event);
    virtual void reset();
    virtual Data serialize();
    virtual void deserialize(const Data& data);

protected:
    std::list<Event> _queue;
    std::recursive_mutex _mutex;
    std::condition_variable_any _cond;
};

}

#endif /* end of include guard: BASICEVENTQUEUE_H_39DCC18B */