From b6a85d646c94f8b1efc51c4a50a644fc902c9521 Mon Sep 17 00:00:00 2001
From: deva <deva>
Date: Sat, 8 Oct 2005 15:56:24 +0000
Subject: *** empty log message ***

---
 src/threadsafe_queue.h | 20 +++++++++++---------
 1 file changed, 11 insertions(+), 9 deletions(-)

(limited to 'src/threadsafe_queue.h')

diff --git a/src/threadsafe_queue.h b/src/threadsafe_queue.h
index 616e81e..b6d5725 100644
--- a/src/threadsafe_queue.h
+++ b/src/threadsafe_queue.h
@@ -28,29 +28,31 @@
 #ifndef __MIAV_THREADSAFE_QUEUE_H__
 #define __MIAV_THREADSAFE_QUEUE_H__
 
-#include <pthread.h>
-#include <semaphore.h>
+#include "mutex.h"
+#include "semaphore.h"
 
 template <typename T>
 class ThreadSafeQueue {
 public:
   ThreadSafeQueue() {
-    pthread_mutex_init (&mutex, NULL);
-    sem_init(&semaphore, 0, 0);
+    //    pthread_mutex_init (&mutex, NULL);
+    //    sem_init(&semaphore, 0, 0);
   }
 
   virtual ~ThreadSafeQueue() {
-    pthread_mutex_destroy(&mutex);
-    sem_destroy(&semaphore);
+    //    pthread_mutex_destroy(&mutex);
+    //sem_destroy(&semaphore);
   }
 
   virtual void push(T t) = 0;
   virtual T pop() = 0;
   virtual int size() = 0;
 
-  //protected:
-  pthread_mutex_t mutex;
-  sem_t semaphore;
+protected:
+  //  pthread_mutex_t mutex;
+  Mutex mutex;
+  //sem_t semaphore;
+  Semaphore semaphore;
 };
 
 #endif/*__MIAV_THREADSAFE_QUEUE_H__*/
-- 
cgit v1.2.3