EventDispatcher.hpp

#pragma once
#include <samchon/API.hpp>

#include <functional>
#include <unordered_set>
#include <unordered_map>

#include <memory>
#include <queue>

#include <condition_variable>
#include <mutex>
#include <samchon/library/RWMutex.hpp>

namespace samchon
{
namespace library
{
    class Event;

    class SAMCHON_FRAMEWORK_API EventDispatcher
    {
    public:
        typedef void(*Listener)(std::shared_ptr<Event>, void*);
        // typedef std::function<void(std::shared_ptr<Event>, void*)> Listener;

    private:
        std::unordered_map<int, std::unordered_map<Listener, std::unordered_set<void*>>> listeners;

        RWMutex mtx;

    public:
        /* ----------------------------------------------------------
            CONSTRUCTORS
        ---------------------------------------------------------- */
        EventDispatcher();

        EventDispatcher(const EventDispatcher &);

        EventDispatcher(EventDispatcher &&);

        virtual ~EventDispatcher();

        /* ----------------------------------------------------------
            ADD-REMOVE EVENT LISTENERS
        ---------------------------------------------------------- */
        void addEventListener(int, Listener, void* = nullptr);

        void removeEventListener(int, Listener, void* = nullptr);

        void dispatch(std::shared_ptr<Event>);

    private:
        void deliver(std::shared_ptr<Event>);

        /* ----------------------------------------------------------
            MEMBERS OF STATIC
        ---------------------------------------------------------- */
        static bool started;
        static std::condition_variable cv;
        static std::mutex cv_mtx;

        static std::unordered_multimap<EventDispatcher*, std::shared_ptr<Event>> eventMap;
        static std::mutex sMtx;

        static void start();

    public:
        static size_t THREAD_SIZE;
    };
};
};