posix/coil/Condition.h

Go to the documentation of this file.

// -*- C++ -*-
#ifndef COIL_CONDITION_H
#define COIL_CONDITION_H

#include <pthread.h>
#include <algorithm>
#include <ctime>
#include <sys/time.h>

namespace coil
{
  template <class M>
  class Condition
  {
  public:

    Condition(M& mutex)
      : m_mutex(mutex)
    {
      ::pthread_cond_init(&m_cond, 0);
    }

    ~Condition()
    {
      ::pthread_cond_destroy(&m_cond);
    }

    inline void signal()
    {
      ::pthread_cond_signal(&m_cond);
    }

    inline void broadcast()
    {
      ::pthread_cond_broadcast(&m_cond);
    }

    bool wait()
    {
      return 0 == ::pthread_cond_wait(&m_cond, &m_mutex.mutex_);
    }

    bool wait(long second, long nano_second = 0)
    {
      struct timeval tv;
      timespec abstime;

      ::gettimeofday(&tv, NULL);
      abstime.tv_sec  = tv.tv_sec + second;
      abstime.tv_nsec = tv.tv_usec * 1000 + nano_second;
      if (abstime.tv_nsec >= 1000000000) {
        abstime.tv_nsec -= 1000000000;
        abstime.tv_sec ++;
      }
      return 0 == ::pthread_cond_timedwait(&m_cond, &m_mutex.mutex_, &abstime);
    }

  private:
    Condition(const M&);
    Condition& operator=(const M &);
    pthread_cond_t m_cond;
    M& m_mutex;
  };
};
#endif // COIL_CONDITION_H