ThreadWithDispatcher.h

#pragma once
 
#include <Foundation/Basics.h>
#include <Foundation/Threading/Thread.h>
 
class PL_FOUNDATION_DLL plThreadWithDispatcher : public plThread
{
public:
  using DispatchFunction = plDelegate<void(), 128>;
 
  plThreadWithDispatcher(const char* szName = "plThreadWithDispatcher", plUInt32 uiStackSize = 128 * 1024);
 
  virtual ~plThreadWithDispatcher();
 
  void Dispatch(DispatchFunction&& delegate);
 
protected:
  void DispatchQueue();
 
private:
  virtual plUInt32 Run() = 0;
 
  plDynamicArray<DispatchFunction> m_ActiveQueue;
  plDynamicArray<DispatchFunction> m_CurrentlyBeingDispatchedQueue;
 
  plMutex m_QueueMutex;
};