summaryrefslogtreecommitdiff
path: root/src/threadsafe_queue_fifo.cc
diff options
context:
space:
mode:
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;