MessageLoop.h

#pragma once
 
#include <Foundation/Basics.h>
#include <Foundation/Configuration/Singleton.h>
#include <Foundation/Configuration/Startup.h>
#include <Foundation/Containers/Deque.h>
#include <Foundation/Threading/Mutex.h>
#include <Foundation/Threading/Thread.h>
 
class plProcessMessage;
class plIpcChannel;
class plLoopThread;
 
class PL_FOUNDATION_DLL plMessageLoop
{
  PL_DECLARE_SINGLETON(plMessageLoop);
 
public:
  plMessageLoop();
  virtual ~plMessageLoop() = default;
  ;
 
  void AddChannel(plIpcChannel* pChannel);
 
  void RemoveChannel(plIpcChannel* pChannel);
 
protected:
  PL_MAKE_SUBSYSTEM_STARTUP_FRIEND(Foundation, MessageLoop);
  friend class plLoopThread;
  friend class plIpcChannel;
 
  void StartUpdateThread();
  void StopUpdateThread();
  void RunLoop();
  bool ProcessTasks();
  void Quit();
 
  virtual void WakeUp() = 0;
  virtual bool WaitForMessages(plInt32 iTimeout, plIpcChannel* pFilter) = 0;
 
  plThreadID m_ThreadId = 0;
  mutable plMutex m_Mutex;
  bool m_bShouldQuit = false;
  bool m_bCallTickFunction = false;
  class plLoopThread* m_pUpdateThread = nullptr;
 
  plMutex m_TasksMutex;
  plDynamicArray<plIpcChannel*> m_ConnectQueue;
  plDynamicArray<plIpcChannel*> m_DisconnectQueue;
  plDynamicArray<plIpcChannel*> m_SendQueue;
 
  // Thread local copies of the different queues for the ProcessTasks method
  plDynamicArray<plIpcChannel*> m_ConnectQueueTask;
  plDynamicArray<plIpcChannel*> m_DisconnectQueueTask;
  plDynamicArray<plIpcChannel*> m_SendQueueTask;
 
  plDynamicArray<plIpcChannel*> m_AllAddedChannels;
};