Default immediate processing queue size is now 10000. Default batch processing queue size is now 20000. Both values are now configurable.

git-svn-id: https://oreka.svn.sourceforge.net/svnroot/oreka/trunk@198 09dcff7a-b715-0410-9601-b79a96267cd0

1 files changed, 6 insertions, 1 deletions

diff --git a/orkaudio/ThreadSafeQueue.h b/orkaudio/ThreadSafeQueue.h
index 7d0c3e3..c14b5b9 100644
--- a/orkaudio/ThreadSafeQueue.h
+++ b/orkaudio/ThreadSafeQueue.h
@@ -26,7 +26,7 @@
 template <class T> class ThreadSafeQueue
 {
 public:
-	ThreadSafeQueue(int size = 2000)
+	ThreadSafeQueue(int size = 10000)
 	{
 		m_size = size;
 		m_semaphore.acquire(); // reset count to zero
@@ -35,6 +35,7 @@ public:
 	bool push(T &);
 	T pop();
 	int numElements();
+	void setSize(int size);
 
 private:
 	int m_size;
@@ -82,6 +83,10 @@ template <class T> int ThreadSafeQueue<T>::numElements()
 	return m_queue.size();
 }
 
+template <class T> void ThreadSafeQueue<T>::setSize(int size)
+{
+	m_size = size;
+}
 
 #endif // __THREADSAFEQUEUE_H__