geventqueue.h

/*
 * File: geventqueue.h
 * -------------------
 *
 * @author Marty Stepp
 * @version 2021/04/03
 * - removed dependency on custom collections
 * @version 2018/09/07
 * - added doc comments for new documentation generation
 * @version 2018/08/23
 * - renamed to geventqueue.h
 * @version 2018/07/03
 * - initial version
 */


#ifndef _geventqueue_h
#define _geventqueue_h

#include <queue>
#include <string>
#include <QObject>
#include <QReadWriteLock>

#include "gevent.h"
#include "gtypes.h"

class GObservable;
class GThread;
class QtGui;

class GEventQueue : public QObject {
    Q_OBJECT

public:
    static GEventQueue* instance();

    int getEventMask() const;

    GEvent getNextEvent(int mask = ANY_EVENT);

    bool isAcceptingEvent(const GEvent& event) const;
    bool isAcceptingEvent(int type) const;

    void setEventMask(int mask);

    GEvent waitForEvent(int mask = ANY_EVENT);

signals:
    void eventReady();

private:
    Q_DISABLE_COPY(GEventQueue)

    /*
     * Prevents construction.  Use instance() instead.
     */
    GEventQueue();

    GThunk dequeue();
    void enqueueEvent(const GEvent& event);
    bool isEmpty() const;
    GThunk peek();
    void runOnQtGuiThreadAsync(GThunk thunk);
    void runOnQtGuiThreadSync(GThunk thunk);

    static GEventQueue* _instance;
    std::queue<GThunk> _functionQueue;
    std::queue<GEvent> _eventQueue;
    QReadWriteLock _eventQueueMutex;
    QReadWriteLock _functionQueueMutex;
    int _eventMask;

    friend class GObservable;
    friend class GThread;
    friend class QtGui;
};

#endif // _geventqueue_h