From 1d30dc5da0c148982032a2b5a5bdece10b3e80ae Mon Sep 17 00:00:00 2001 From: deva Date: Sat, 8 Oct 2005 16:24:33 +0000 Subject: *** empty log message *** --- src/threadsafe_queue_fifo.cc | 23 +++++++++-------------- 1 file changed, 9 insertions(+), 14 deletions(-) (limited to 'src/threadsafe_queue_fifo.cc') 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 -ThreadSafeQueueFIFO::ThreadSafeQueueFIFO() +ThreadSafeQueueFIFO::ThreadSafeQueueFIFO() { } -template -ThreadSafeQueueFIFO::~ThreadSafeQueueFIFO() +ThreadSafeQueueFIFO::~ThreadSafeQueueFIFO() { } -template -void ThreadSafeQueueFIFO::push(T t) +void ThreadSafeQueueFIFO::push(FrameVector *framevector) { mutex.lock(); - queue.push(t); + queue.push(framevector); mutex.unlock(); semaphore.post(); } -template -T ThreadSafeQueueFIFO::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 -int ThreadSafeQueueFIFO::size() +int ThreadSafeQueueFIFO::size() { int sz; -- cgit v1.2.3