jobcommon.h

#pragma once
 
#include <inttypes.h>
// TODO: Currently necessary due to std::function. Replace them!
#include <functional>
 
#include "gaia/core/utility.h"
#include "gaia/mt/event.h"
#include "gaia/mt/jobqueue.h"
 
namespace gaia {
  namespace mt {
    enum class JobPriority : uint8_t {
      High = 0,
      Low = 1
    };
    static inline constexpr uint32_t JobPriorityCnt = 2;
 
    enum JobCreationFlags : uint8_t {
      Default = 0,
      ManualDelete = 0x01,
      CanWait = 0x02
    };
 
    struct JobAllocCtx {
      JobPriority priority;
    };
 
    struct Job {
      std::function<void()> func;
      JobPriority priority = JobPriority::High;
      JobCreationFlags flags = JobCreationFlags::Default;
    };
 
    struct JobArgs {
      uint32_t idxStart;
      uint32_t idxEnd;
    };
 
    struct JobParallel {
      std::function<void(const JobArgs&)> func;
      JobPriority priority = JobPriority::High;
    };
 
    class ThreadPool;
 
    struct ThreadCtx {
      ThreadPool* tp;
      uint32_t workerIdx;
      JobPriority prio;
      Event event;
      JobQueue<512> jobQueue;
 
      ThreadCtx() = default;
      ~ThreadCtx() = default;
 
      void reset() {
        event.reset();
        jobQueue.clear();
      }
 
      ThreadCtx(const ThreadCtx& other) = delete;
      ThreadCtx& operator=(const ThreadCtx& other) = delete;
      ThreadCtx(ThreadCtx&& other) = delete;
      ThreadCtx& operator=(ThreadCtx&& other) = delete;
    };
  } // namespace mt
} // namespace gaia