nsbaciScheduler.h

Go to the documentation of this file.

 
#ifndef NSBACI_SERVICES_RUNTIME_NSBACI_SCHEDULER_H
#define NSBACI_SERVICES_RUNTIME_NSBACI_SCHEDULER_H
 
#include "scheduler.h"

namespace nsbaci::services::runtime {

class NsbaciScheduler final : public Scheduler {
 public:
  NsbaciScheduler() = default;
  ~NsbaciScheduler() override = default;
 
  Thread* pickNext() override;
  void addThread(Thread thread) override;
  void blockCurrent() override;
  void blockOnSemaphore(uint32_t semaphoreAddr) override;
  size_t unblockSemaphore(uint32_t semaphoreAddr) override;
  void unblock(nsbaci::types::ThreadID threadId) override;
  void yield() override;
  void terminateCurrent() override;
  bool hasThreads() const override;
  Thread* current() override;
  void clear() override;
  void unblockIO() override;
  const std::vector<Thread>& getThreads() const override;
  void blockOnCoend(int32_t expectedThreads) override;
  void checkCoendUnblock() override;
 
 private:
  std::optional<size_t> findThreadIndex(nsbaci::types::ThreadID threadId) const;
};
 
}  // namespace nsbaci::services::runtime
 
#endif  // NSBACI_SERVICES_RUNTIME_NSBACI_SCHEDULER_H