/ray/src/lib/threads/condition.h

Go to the documentation of this file.

/*
 * lib/threads/condition.h
 * 
 * Implementing a thread condition; an object that threads can block 
 * on, if they find a certain condition to be false. 
 * 
 * Copyright (c) 2004 by Wolfgang Wieser ] wwieser (a) gmx <*> de [ 
 * 
 * This file may be distributed and/or modified under the terms of the 
 * GNU General Public License version 2 as published by the Free Software 
 * Foundation. (See COPYING.GPL for details.)
 * 
 * This file is provided AS IS with NO WARRANTY OF ANY KIND, INCLUDING THE
 * WARRANTY OF DESIGN, MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE.
 * 
 */

#ifndef _ThreadLibrary_WaitCondition_H_
#define _ThreadLibrary_WaitCondition_H_ 1

#include <lib/sconfig.h>    /* MUST be first */

/* Can we use our own pthreads-based implementation? This should be faster.*/
#if USE_PRIVATE__PTHREADS
# include <errno.h>   /* for EGAGIN */
# include <pthread.h>
#else
# include <glib/gthread.h>
#endif  /* USE_PRIVATE__PTHREADS */

#include <lib/threads/mutex.h>


class WaitCondition
{
    private:
#if USE_PRIVATE__PTHREADS
        pthread_cond_t c;
#else
        GCond *c;
#endif
        
    public:
        WaitCondition();
        
        ~WaitCondition();
        
        inline void signal()
#if USE_PRIVATE__PTHREADS
            {  pthread_cond_signal(&c);  }
#else
            {  g_cond_signal(c);  }
#endif
        
        inline void broadcast()
#if USE_PRIVATE__PTHREADS
            {  pthread_cond_broadcast(&c);  }
#else
            {  g_cond_broadcast(c);  }
#endif
        
        inline void wait(ConditionMutex &m)
#if USE_PRIVATE__PTHREADS
            {  pthread_cond_wait(&c,&m.m);  }
#else
            {  g_cond_wait(c,m.m);  }
#endif
        
        int wait(ConditionMutex &m,long msec);
        
};

#endif  /* _ThreadLibrary_WaitCondition_H_ */

---