From 59dbcc1245468218ec7e2372b2678351382a34f0 Mon Sep 17 00:00:00 2001 From: danieldg Date: Mon, 23 Mar 2009 18:48:51 +0000 Subject: ThreadEngine: Allow interthread signaling without needing as many hacks git-svn-id: http://svn.inspircd.org/repository/trunk/inspircd@11251 e03df62e-2008-0410-955e-edbf42e46eb7 --- include/threadengines/threadengine_pthread.h | 46 ++++++++++++++++++++++++++++ 1 file changed, 46 insertions(+) (limited to 'include/threadengines/threadengine_pthread.h') diff --git a/include/threadengines/threadengine_pthread.h b/include/threadengines/threadengine_pthread.h index 2aba4cb15..bad263d18 100644 --- a/include/threadengines/threadengine_pthread.h +++ b/include/threadengines/threadengine_pthread.h @@ -107,4 +107,50 @@ class CoreExport Mutex } }; +class ThreadQueueData +{ + pthread_mutex_t mutex; + pthread_cond_t cond; + public: + ThreadQueueData() + { + pthread_mutex_init(&mutex, NULL); + pthread_cond_init(&cond, NULL); + } + + ~ThreadQueueData() + { + pthread_mutex_destroy(&mutex); + pthread_cond_destroy(&cond); + } + + void Lock() + { + pthread_mutex_lock(&mutex); + } + + void Unlock() + { + pthread_mutex_unlock(&mutex); + } + + void Wakeup() + { + pthread_cond_signal(&cond); + } + + void Wait() + { + pthread_cond_wait(&cond, &mutex); + } +}; + +class ThreadSignalSocket; +class ThreadSignalData +{ + public: + ThreadSignalSocket* sock; +}; + + #endif -- cgit v1.2.3