synchro.h

   1 #ifndef SYNCHRO_H
   2 #define SYNCHRO_H
   3
   4 #include <xbt/synchro.h>
   5
   6 class mutex_t {
   7 public:
   8     mutex_t()                   { mutex = xbt_mutex_init(); }
   9     ~mutex_t()                  { xbt_mutex_destroy(mutex); }
  10     void acquire()              { xbt_mutex_acquire(mutex); }
  11     void release()              { xbt_mutex_release(mutex); }
  12
  13 private:
  14     xbt_mutex_t mutex;
  15
  16     friend class condition_t;
  17 };
  18
  19 class condition_t {
  20 public:
  21     condition_t()               { cond = xbt_cond_init();           }
  22     ~condition_t()              { xbt_cond_destroy(cond);           }
  23     void broadcast()            { xbt_cond_broadcast(cond);         }
  24     void signal()               { xbt_cond_signal(cond);            }
  25     void wait(mutex_t& mutex)   { xbt_cond_wait(cond, mutex.mutex); }
  26     bool timedwait(mutex_t& mutex, double delay) {
  27         if (xbt_cond_timedwait(cond, mutex.mutex, delay)) {
  28             mutex.acquire();
  29             return false;       // got a timeout
  30         }
  31         return true;
  32     }
  33
  34 private:
  35     xbt_cond_t cond;
  36 };
  37
  38 #endif // !SYNCHRO_H
  39
  40 // Local variables:
  41 // mode: c++
  42 // End: