diff options
author | deva <deva> | 2005-10-08 16:24:33 +0000 |
---|---|---|
committer | deva <deva> | 2005-10-08 16:24:33 +0000 |
commit | 1d30dc5da0c148982032a2b5a5bdece10b3e80ae (patch) | |
tree | 4e698b0a27d2cfb98c95a536f361ce1145f8a119 /src/threadsafe_queue_fifo.cc | |
parent | 48775e1ce9eb0dd53908110454d068a8b16a66ec (diff) |
*** empty log message ***R0_3_0
Diffstat (limited to 'src/threadsafe_queue_fifo.cc')
-rw-r--r-- | src/threadsafe_queue_fifo.cc | 23 |
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; |