X-Git-Url: http://git.tdb.fi/?p=libs%2Fcore.git;a=blobdiff_plain;f=source%2Fcore%2Fmutex.h;fp=source%2Fcore%2Fmutex.h;h=b619fcdb7c6b9127a550a296c9f4cb521d0d3ecc;hp=0000000000000000000000000000000000000000;hb=e1ea831a640fba534e7e42e399f04cdf681ef8d3;hpb=0bcb8d4d6f33cbdad7b921cac787740bfe8e212e

diff --git a/source/core/mutex.h b/source/core/mutex.h
new file mode 100644
index 0000000..b619fcd
--- /dev/null
+++ b/source/core/mutex.h
@@ -0,0 +1,73 @@
+/*
+This file is part of libmspframework
+Copyright © 2006 Mikko Rasa, Mikkosoft Productions
+Distributed under the LGPL
+*/
+#ifndef MSP_FRAMEWORK_MUTEX_H_
+#define MSP_FRAMEWORK_MUTEX_H_
+
+#include <msp/refcount.h>
+#include "types.h"
+
+namespace Msp {
+
+class Mutex
+{
+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
+private:
+	MutexHandle mutex;
+
+	friend class Semaphore;
+};
+
+class MutexLock
+{
+public:
+	MutexLock(Mutex &m): mutex(m) { mutex.lock(); }
+	~MutexLock()                  { mutex.unlock(); }
+private:
+	Mutex &mutex;
+};
+
+
+template<typename T>
+class MutexPtr: public RefCount
+{
+public:
+	MutexPtr(T *d, Mutex &m): mutex(m), data(d) { mutex.lock(); }
+	MutexPtr(const MutexPtr<T> &p): RefCount(p), mutex(p.mutex), data(p.data) { }
+	T &operator*() const { return *data; }
+	T *operator->() const { return data; }
+	void clear() { decref(); data=0; }
+	~MutexPtr() { decref(); }
+protected:
+	Mutex &mutex;
+	T     *data;
+
+	bool decref()
+	{
+		if(!RefCount::decref())
+		{
+			mutex.unlock();
+			return false;
+		}
+		return true;
+	}
+};
+
+}
+
+#endif