X-Git-Url: http://git.tdb.fi/?p=libs%2Fcore.git;a=blobdiff_plain;f=source%2Fcore%2Fmutex.h;h=050d00f808a6d42f29e8cbf14744e935bad604d4;hp=50a64e55aaa0a87a1a6d114960ed5cd3416e5527;hb=967785734be5c3fc6f75da122c2d93ebbb338271;hpb=cfc8e0b7b15ea505bd6a6a9599cbc5ce1e316963 diff --git a/source/core/mutex.h b/source/core/mutex.h index 50a64e5..050d00f 100644 --- a/source/core/mutex.h +++ b/source/core/mutex.h @@ -1,39 +1,37 @@ -/* $Id$ - -This file is part of libmspcore -Copyright © 2006 Mikko Rasa, Mikkosoft Productions -Distributed under the LGPL -*/ - #ifndef MSP_CORE_MUTEX_H_ #define MSP_CORE_MUTEX_H_ #include "refptr.h" -#include "types.h" namespace Msp { +/** +A class for controlling mutually exclusive access to a resource. Only one +thread can hold a lock on the mutex at a time. +*/ class Mutex { friend class Semaphore; private: - MutexHandle mutex; + struct Private; + + Private *priv; public: -#ifndef WIN32 - Mutex() { pthread_mutex_init(&mutex, 0); } - int lock() { return pthread_mutex_lock(&mutex); } - int trylock() { return pthread_mutex_trylock(&mutex); } - int unlock() { return pthread_mutex_unlock(&mutex); } - ~Mutex() { pthread_mutex_destroy(&mutex); } -#else - Mutex() { mutex=CreateMutex(0, false, 0); } - int lock() { return WaitForSingleObject(mutex, INFINITE)==WAIT_OBJECT_0; } - int trylock() { return WaitForSingleObject(mutex, 0)==WAIT_OBJECT_0; } - int unlock() { return !ReleaseMutex(mutex); } - ~Mutex() { CloseHandle(mutex); } -#endif + Mutex(); + ~Mutex(); + + /** Locks the mutex. If the mutex is already locked, waits until it becomes + available. */ + void lock(); + + /** Attempts to lock the mutex. Returns true if the lock was acquired, + otherwise returns false. */ + bool trylock(); + + /** Unlocks the mutex. */ + void unlock(); }; /** @@ -45,10 +43,10 @@ private: Mutex &mutex; public: - MutexLock(Mutex &m, bool l=true): mutex(m) { if(l) mutex.lock(); } + MutexLock(Mutex &m, bool l = true): mutex(m) { if(l) mutex.lock(); } ~MutexLock() { mutex.unlock(); } - int lock() { return mutex.lock(); } + void lock() { mutex.lock(); } private: MutexLock(const MutexLock &); MutexLock &operator=(const MutexLock &); @@ -66,7 +64,7 @@ public: T &operator*() const { return *data; } T *operator->() const { return data; } - void clear() { mutex=0; data=0; } + void clear() { mutex=0; data = 0; } private: RefPtr mutex; T *data; @@ -80,7 +78,7 @@ public: MutexPtr(const MutexPtr &p): RefCount(p), mutex(p.mutex), data(p.data) { } T &operator*() const { return *data; } T *operator->() const { return data; } - void clear() { decref(); data=0; } + void clear() { decref(); data = 0; } ~MutexPtr() { decref(); } protected: Mutex &mutex;