EditorEventQueue.h

Go to the documentation of this file.

#pragma once
 
#include "EditorCore/Thread/Threads.h"
 
#include <Utility/Concurrent/TAtomicQuasiQueue.h>
#include <Utility/TFunction.h>
 
#include <cstddef>
#include <vector>
#include <utility>
 
namespace ph::editor
{
 
class EditorEventQueue final
{
public:
    // Safe limit of concurrent works executed to avoid starvation on main thread works
    inline constexpr static std::size_t maxAnyThreadWorksPerUpdate = 1024;
 
    using EventUpdateWork = TFunction<void(void)>;
 
    EditorEventQueue();
 
    void add(EventUpdateWork work);
 
    void flushAllEvents();
 
private:
    void updateMainThreadEvents();
    void updateAnyThreadEvents();
 
    std::vector<EventUpdateWork> m_mainThreadWorks;
    TAtomicQuasiQueue<EventUpdateWork> m_anyThreadWorks;
};
 
inline void EditorEventQueue::add(EventUpdateWork work)
{
    if(Threads::isOnMainThread())
    {
        m_mainThreadWorks.push_back(std::move(work));
    }
    else
    {
        m_anyThreadWorks.enqueue(std::move(work));
    }
}
 
}// end namespace ph::editor