async.hpp

#pragma once
 
#include <atomic>
 
#include "libxr_cb.hpp"
#include "libxr_def.hpp"
#include "semaphore.hpp"
#include "thread.hpp"
 
namespace LibXR
{
 
class ASync
{
 public:
  enum class Status : uint32_t
  {
    READY = 0,         
    BUSY = 1,          
    DONE = UINT32_MAX  
  };
 
  ASync(size_t stack_depth, Thread::Priority priority);
 
  static void ThreadFun(ASync *async)
  {
    while (true)
    {
      if (async->sem_.Wait() == ErrorCode::OK)
      {
        async->job_.Run(false, async);
        async->status_ = Status::DONE;
      }
    }
  }
 
  std::atomic<Status> status_ = Status::READY;  
 
  [[nodiscard]] Status GetStatus()
  {
    Status cur = status_.load();
    if (cur != Status::DONE)
    {
      return cur;
    }
    status_ = Status::READY;
    return Status::DONE;
  }
 
  using Job = LibXR::Callback<ASync *>;
 
  ErrorCode AssignJob(Job job);
 
  void AssignJobFromCallback(Job job, bool in_isr)
  {
    job_ = job;
    status_.store(Status::BUSY);
    sem_.PostFromCallback(in_isr);
  }
 
  Job job_;  
  Semaphore sem_;  
 
  Thread thread_handle_;  
};
 
}  // namespace LibXR