async.hpp

#pragma once
 
#include "libxr_cb.hpp"
#include "libxr_def.hpp"
#include "semaphore.hpp"
#include "thread.hpp"
 
namespace LibXR
{
 
class ASync
{
 public:
  enum class Status : uint8_t
  {
    REDAY,  
    BUSY,   
    DONE    
  };
 
  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;
      }
    }
  }
 
  Status status_ =
      Status::REDAY;  
 
  Status GetStatus()
  {
    if (status_ != Status::DONE)
    {
      return status_;
    }
    else
    {
      status_ = Status::REDAY;
      return Status::DONE;
    }
  }
 
  using Callback = LibXR::Callback<ASync *>;
 
  ErrorCode AssignJob(Callback job);
 
  void AssignJobFromCallback(Callback job, bool in_isr)
  {
    job_ = job;
    status_ = Status::BUSY;
    sem_.PostFromCallback(in_isr);
  }
 
  Callback
      job_;  
  Semaphore sem_;  
 
  Thread thread_handle_;  
};
 
}  // namespace LibXR