1 files changed, 33 insertions, 0 deletions

diff --git a/src/pqueue.cpp b/src/pqueue.cpp
new file mode 100644
index 0000000..1f0b8b5
--- /dev/null
+++ b/src/pqueue.cpp
@@ -0,0 +1,33 @@
+#include "pqueue.h"
+
+PQueue::PQueue( int nNewNumQueues )
+{
+        nNumQueues = nNewNumQueues;
+        aQueue = new Queue[nNumQueues];
+}
+
+PQueue::~PQueue()
+{
+        delete[] aQueue;
+}
+
+void PQueue::enqueue( void *pData, int nQueueLevel )
+{
+        if( nQueueLevel < 0 || nQueueLevel >= nNumQueues )
+                return;
+
+        aQueue[nQueueLevel].enqueue( pData );
+}
+
+void *PQueue::dequeue()
+{
+        for( int j = 0; j < nNumQueues; j++ )
+        {
+                if( aQueue[j].isEmpty() == false )
+                {
+                        return aQueue[j].dequeue();
+                }
+        }
+
+        return NULL;
+}