|
@@ -26,6 +26,60 @@ THE SOFTWARE
|
|
|
#pragma once
|
|
#pragma once
|
|
|
|
|
|
|
|
#define CM_AUTO_MUTEX_NAME mutex
|
|
#define CM_AUTO_MUTEX_NAME mutex
|
|
|
|
|
+
|
|
|
|
|
+#if CM_THREAD_SUPPORT
|
|
|
|
|
+
|
|
|
|
|
+// TODO - Port this to std threads so we aren't dependent on boost
|
|
|
|
|
+
|
|
|
|
|
+#include <boost/thread/tss.hpp>
|
|
|
|
|
+#include <boost/thread/recursive_mutex.hpp>
|
|
|
|
|
+#include <boost/thread/condition.hpp>
|
|
|
|
|
+#include <boost/thread/thread.hpp>
|
|
|
|
|
+#include <boost/thread/shared_mutex.hpp>
|
|
|
|
|
+#include <boost/thread/locks.hpp>
|
|
|
|
|
+
|
|
|
|
|
+#define CM_AUTO_MUTEX mutable boost::recursive_mutex CM_AUTO_MUTEX_NAME;
|
|
|
|
|
+#define CM_LOCK_AUTO_MUTEX boost::recursive_mutex::scoped_lock cmAutoMutexLock(CM_AUTO_MUTEX_NAME);
|
|
|
|
|
+#define CM_MUTEX(name) mutable boost::recursive_mutex name;
|
|
|
|
|
+#define CM_STATIC_MUTEX(name) static boost::recursive_mutex name;
|
|
|
|
|
+#define CM_STATIC_MUTEX_INSTANCE(name) boost::recursive_mutex name;
|
|
|
|
|
+#define CM_LOCK_MUTEX(name) boost::recursive_mutex::scoped_lock cmnameLock(name);
|
|
|
|
|
+#define CM_LOCK_MUTEX_NAMED(mutexName, lockName) boost::recursive_mutex::scoped_lock lockName(mutexName);
|
|
|
|
|
+// like CM_AUTO_MUTEX but mutex held by pointer
|
|
|
|
|
+#define CM_AUTO_SHARED_MUTEX mutable boost::recursive_mutex *CM_AUTO_MUTEX_NAME;
|
|
|
|
|
+#define CM_LOCK_AUTO_SHARED_MUTEX assert(CM_AUTO_MUTEX_NAME); boost::recursive_mutex::scoped_lock cmAutoMutexLock(*CM_AUTO_MUTEX_NAME);
|
|
|
|
|
+#define CM_NEW_AUTO_SHARED_MUTEX assert(!CM_AUTO_MUTEX_NAME); CM_AUTO_MUTEX_NAME = new boost::recursive_mutex();
|
|
|
|
|
+#define CM_DELETE_AUTO_SHARED_MUTEX assert(CM_AUTO_MUTEX_NAME); delete CM_AUTO_MUTEX_NAME;
|
|
|
|
|
+#define CM_COPY_AUTO_SHARED_MUTEX(from) assert(!CM_AUTO_MUTEX_NAME); CM_AUTO_MUTEX_NAME = from;
|
|
|
|
|
+#define CM_SET_AUTO_SHARED_MUTEX_NULL CM_AUTO_MUTEX_NAME = 0;
|
|
|
|
|
+#define CM_MUTEX_CONDITIONAL(mutex) if (mutex)
|
|
|
|
|
+#define CM_THREAD_SYNCHRONISER(sync) boost::condition sync;
|
|
|
|
|
+#define CM_THREAD_WAIT(sync, mutex, lock) sync.wait(lock);
|
|
|
|
|
+#define CM_THREAD_NOTIFY_ONE(sync) sync.notify_one();
|
|
|
|
|
+#define CM_THREAD_NOTIFY_ALL(sync) sync.notify_all();
|
|
|
|
|
+// Read-write mutex
|
|
|
|
|
+#define CM_RW_MUTEX(name) mutable boost::shared_mutex name
|
|
|
|
|
+#define CM_LOCK_RW_MUTEX_READ(name) boost::shared_lock<boost::shared_mutex> cmnameLock(name)
|
|
|
|
|
+#define CM_LOCK_RW_MUTEX_WRITE(name) boost::unique_lock<boost::shared_mutex> cmnameLock(name)
|
|
|
|
|
+// Thread-local pointer
|
|
|
|
|
+#define CM_THREAD_POINTER(T, var) boost::thread_specific_ptr<T> var
|
|
|
|
|
+#define CM_THREAD_POINTER_INIT(var) var(&deletePtr)
|
|
|
|
|
+#define CM_THREAD_POINTER_VAR(T, var) boost::thread_specific_ptr<T> var (&deletePtr<T>)
|
|
|
|
|
+#define CM_THREAD_POINTER_SET(var, expr) var.reset(expr)
|
|
|
|
|
+#define CM_THREAD_POINTER_GET(var) var.get()
|
|
|
|
|
+#define CM_THREAD_POINTER_DELETE(var) var.reset(0)
|
|
|
|
|
+// Thread objects and related functions
|
|
|
|
|
+#define CM_THREAD_TYPE boost::thread
|
|
|
|
|
+#define CM_THREAD_CREATE(name, worker) boost::thread* name = new boost::thread(worker);
|
|
|
|
|
+#define CM_THREAD_DESTROY(name) delete name;
|
|
|
|
|
+#define CM_THREAD_HARDWARE_CONCURRENCY boost::thread::hardware_concurrency()
|
|
|
|
|
+#define CM_THREAD_CURRENT_ID boost::this_thread::get_id()
|
|
|
|
|
+#define CM_THREAD_WORKER_INHERIT
|
|
|
|
|
+// Utility
|
|
|
|
|
+#define CM_THREAD_SLEEP(ms) boost::this_thread::sleep(boost::posix_time::millisec(ms));
|
|
|
|
|
+
|
|
|
|
|
+#else
|
|
|
|
|
+
|
|
|
#define CM_AUTO_MUTEX
|
|
#define CM_AUTO_MUTEX
|
|
|
#define CM_LOCK_AUTO_MUTEX
|
|
#define CM_LOCK_AUTO_MUTEX
|
|
|
#define CM_MUTEX(name)
|
|
#define CM_MUTEX(name)
|
|
@@ -55,3 +109,6 @@ THE SOFTWARE
|
|
|
#define CM_THREAD_POINTER_DELETE(var) { delete var; var = 0; }
|
|
#define CM_THREAD_POINTER_DELETE(var) { delete var; var = 0; }
|
|
|
#define CM_THREAD_SLEEP(ms)
|
|
#define CM_THREAD_SLEEP(ms)
|
|
|
#define CM_THREAD_WORKER_INHERIT
|
|
#define CM_THREAD_WORKER_INHERIT
|
|
|
|
|
+
|
|
|
|
|
+#endif
|
|
|
|
|
+
|