semaphore.h

Go to the documentation of this file.

 
#ifndef NSBACI_RUNTIME_SEMAPHORE_H
#define NSBACI_RUNTIME_SEMAPHORE_H
 
#include <cstdint>
#include <unordered_map>
 
#include "compilerTypes.h"
#include "thread.h"
 
namespace nsbaci::services::runtime {

class Semaphore {
 public:
  explicit Semaphore(int32_t initialCount = 0) : count(initialCount) {}

  bool wait(nsbaci::types::ThreadID currentThread);

  nsbaci::types::ThreadID signal();

  int32_t getCount() const { return count; }

  bool hasWaiting() const { return !blocked.empty(); }
 
 private:
  std::queue<nsbaci::types::ThreadID> blocked;  
  int32_t count;                       
};
 
}  // namespace nsbaci::services::runtime
 
namespace nsbaci::types {

using SemaphoreTable =
    std::unordered_map<MemoryAddr, nsbaci::services::runtime::Semaphore>;
 
}  // namespace nsbaci::types
 
#endif  // NSBACI_RUNTIME_SEMAPHORE_H