X-Git-Url: http://git.tdb.fi/?p=libs%2Fcore.git;a=blobdiff_plain;f=source%2Fcore%2Fsemaphore.h;h=28c3b3d72cb8f009fd4474cfa73ab586db1a1d02;hp=75c51e6a424716deee151e3bedfd7eb80342e006;hb=HEAD;hpb=e1ea831a640fba534e7e42e399f04cdf681ef8d3 diff --git a/source/core/semaphore.h b/source/core/semaphore.h index 75c51e6..f504289 100644 --- a/source/core/semaphore.h +++ b/source/core/semaphore.h @@ -1,32 +1,26 @@ -/* -This file is part of libmspframework -Copyright © 2006 Mikko Rasa, Mikkosoft Productions -Distributed under the LGPL -*/ -#ifndef MSP_FRAMEWORK_SEMAPHORE_H_ -#define MSP_FRAMEWORK_SEMAPHORE_H_ - -#include -#include "mutex.h" -#include "../time/timedelta.h" +#ifndef MSP_CORE_SEMAPHORE_H_ +#define MSP_CORE_SEMAPHORE_H_ + +#include +#include "mspcore_api.h" +#include "noncopyable.h" namespace Msp { -class Semaphore +class MSPCORE_API Semaphore: private NonCopyable { -public: -#ifndef WIN32 - Semaphore() { pthread_cond_init(&cond, 0); } - //Mutex &get_mutex() { return mutex; } - int signal() { MutexLock l(mutex); return pthread_cond_signal(&cond); } - int broadcast() { MutexLock l(mutex); return pthread_cond_broadcast(&cond); } - int wait() { mutex.lock(); return pthread_cond_wait(&cond, &mutex.mutex); } - int wait(const Time::TimeDelta &); - ~Semaphore() { pthread_cond_destroy(&cond); } -#endif private: - Mutex mutex; - pthread_cond_t cond; + struct Private; + + Private *priv = nullptr; + +public: + Semaphore(unsigned); + ~Semaphore(); + + void signal(); + void wait(); + bool wait(const Time::TimeDelta &); }; }