ysemaphore.h

説明を見る。

#ifndef DEFINE_H_YSEMAPHORE
#define DEFINE_H_YSEMAPHORE

#include <basic.h>
#include <btron/taskcomm.h>
#include "yexception.h"

class YSemaphoreException : public YException {
public:
  YSemaphoreException(W n = 0) : YException(n) {}
  YSemaphoreException(const YString& str, W n = 0)
    : YException(str, n) {}
};

struct YSemaphoreInstance {
  W sem_id;
  W refcount;
};

class YSemaphore {
private:
  mutable YSemaphoreInstance *sem;
  W max_count;
  W mode;

  W getInternalSemaphoreID() const;

  YSemaphoreInstance* getInstance() const;

  void reductInstanceReferrer();

protected:

public:
  YSemaphore(W cnt = 1, W mode = SEM_EXCL);
  
  ~YSemaphore() {
    W global_sem = getInternalSemaphoreID();
    wai_sem(global_sem, T_FOREVER);
    // クリティカルセクション開始
    try {
      reductInstanceReferrer();
    }
    catch (...){
      sig_sem(global_sem);
      throw;
    }
    // クリティカルセクション終了
    sig_sem(global_sem);
  }

  // コピーコンストラクタ
  YSemaphore(const YSemaphore& src);

  void lock();

  void unlock();

  const YSemaphore& operator=(const YSemaphore& src);
  
};

#endif // DEFINE_H_YSEMAPHORE

---