Change name: PriorityQueue -> ConcurrentPriorityQueue

ZjzMisaka · Mar 12, 2024 · bb220fe · bb220fe
1 parent 368dfd8
commit bb220fe
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/PowerThreadPool/Collections/PriorityQueue.cs → ...ol/Collections/ConcurrentPriorityQueue.cs b/PowerThreadPool/Collections/PriorityQueue.cs → ...ol/Collections/ConcurrentPriorityQueue.cs
@@ -6,14 +6,14 @@
 
 namespace PowerThreadPool.Collections
 {
-    public class PriorityQueue<T>
+    public class ConcurrentPriorityQueue<T>
     {
         private ConcurrentDictionary<int, ConcurrentQueue<T>> queueDic;
         private ConcurrentSet<int> prioritySet;
         private List<int> reversed;
         private int updated;
 
-        public PriorityQueue()
+        public ConcurrentPriorityQueue()
         {
             queueDic = new ConcurrentDictionary<int, ConcurrentQueue<T>>();
             prioritySet = new ConcurrentSet<int>();

diff --git a/PowerThreadPool/Worker.cs b/PowerThreadPool/Worker.cs
@@ -20,7 +20,7 @@ public class Worker
         internal int workerState = WorkerStates.Idle;
         internal int gettedLock = WorkerGettedFlags.Unlocked;
 
-        private PriorityQueue<string> waitingWorkIDQueue = new PriorityQueue<string>();
+        private ConcurrentPriorityQueue<string> waitingWorkIDQueue = new ConcurrentPriorityQueue<string>();
         private ConcurrentDictionary<string, WorkBase> waitingWorkDic = new ConcurrentDictionary<string, WorkBase>();
 
         private System.Timers.Timer timeoutTimer;