X-Git-Url: https://git.netwichtig.de/gitweb/?a=blobdiff_plain;f=include%2Fthreadengines%2Fthreadengine_pthread.h;h=ca33542607839ea168c48cb750af928552cca35b;hb=b30988ee6069a6ebe0805fb79a057d7e05688bc6;hp=454e3ea4a3ac60279dcecb0273841733102c2b68;hpb=a77b9081d4e17bfe8b887073c09d531b2f4c4842;p=user%2Fhenk%2Fcode%2Finspircd.git diff --git a/include/threadengines/threadengine_pthread.h b/include/threadengines/threadengine_pthread.h index 454e3ea4a..ca3354260 100644 --- a/include/threadengines/threadengine_pthread.h +++ b/include/threadengines/threadengine_pthread.h @@ -74,7 +74,7 @@ class CoreExport ThreadEngine */ class CoreExport Mutex { - private: + protected: pthread_mutex_t putex; public: /** Constructor. @@ -103,33 +103,20 @@ class CoreExport Mutex } }; -class ThreadQueueData +class ThreadQueueData : public Mutex { - 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); @@ -137,7 +124,7 @@ class ThreadQueueData void Wait() { - pthread_cond_wait(&cond, &mutex); + pthread_cond_wait(&cond, &putex); } };