summaryrefslogtreecommitdiff
path: root/src/threadsafe_queue_fifo.cc
diff options
context:
space:
mode:
authordeva <deva>2005-10-08 16:24:33 +0000
committerdeva <deva>2005-10-08 16:24:33 +0000
commit1d30dc5da0c148982032a2b5a5bdece10b3e80ae (patch)
tree4e698b0a27d2cfb98c95a536f361ce1145f8a119 /src/threadsafe_queue_fifo.cc
parent48775e1ce9eb0dd53908110454d068a8b16a66ec (diff)
*** empty log message ***R0_3_0
Diffstat (limited to 'src/threadsafe_queue_fifo.cc')
-rw-r--r--src/threadsafe_queue_fifo.cc23
1 files changed, 9 insertions, 14 deletions
diff --git a/src/threadsafe_queue_fifo.cc b/src/threadsafe_queue_fifo.cc
index 50c1067..6dbcb67 100644
--- a/src/threadsafe_queue_fifo.cc
+++ b/src/threadsafe_queue_fifo.cc
@@ -27,43 +27,38 @@
#include "config.h"
#include "threadsafe_queue_fifo.h"
-template <typename T>
-ThreadSafeQueueFIFO<T>::ThreadSafeQueueFIFO()
+ThreadSafeQueueFIFO::ThreadSafeQueueFIFO()
{
}
-template <typename T>
-ThreadSafeQueueFIFO<T>::~ThreadSafeQueueFIFO()
+ThreadSafeQueueFIFO::~ThreadSafeQueueFIFO()
{
}
-template <typename T>
-void ThreadSafeQueueFIFO<T>::push(T t)
+void ThreadSafeQueueFIFO::push(FrameVector *framevector)
{
mutex.lock();
- queue.push(t);
+ queue.push(framevector);
mutex.unlock();
semaphore.post();
}
-template <typename T>
-T ThreadSafeQueueFIFO<T>::pop()
+FrameVector *ThreadSafeQueueFIFO::pop()
{
semaphore.wait();
- T t;
+ FrameVector *framevector;
mutex.lock();
- t = queue.front();
+ framevector = queue.front();
queue.pop();
mutex.unlock();
- return t;
+ return framevector;
}
-template <typename T>
-int ThreadSafeQueueFIFO<T>::size()
+int ThreadSafeQueueFIFO::size()
{
int sz;