global queue is delayQueue

Author: luxl

dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/runner/GlobalTaskDispatchWaitingQueue.java

@@ -43,7 +43,7 @@ public class GlobalTaskDispatchWaitingQueue {
 
     private final Set<Integer> waitingTaskInstanceIds = ConcurrentHashMap.newKeySet();
 
-    private final PriorityBlockingQueue<TimeBasedTaskExecutionRunnableComparableEntry> priorityQueue =
+    private final PriorityBlockingQueue<TimeBasedTaskExecutionRunnableComparableEntry> delayQueue =
             new PriorityBlockingQueue<>();
 
     /**
@@ -59,17 +59,17 @@ public synchronized void dispatchTaskExecuteRunnable(ITaskExecutionRunnable iTas
     public synchronized void dispatchTaskExecuteRunnableWithDelay(ITaskExecutionRunnable taskExecutionRunnable,
                                                                   long delayTimeMills) {
         waitingTaskInstanceIds.add(taskExecutionRunnable.getTaskInstance().getId());
-        priorityQueue.add(new TimeBasedTaskExecutionRunnableComparableEntry(delayTimeMills, taskExecutionRunnable));
+        delayQueue.add(new TimeBasedTaskExecutionRunnableComparableEntry(delayTimeMills, taskExecutionRunnable));
     }
 
     /**
      * Consume {@link ITaskExecutionRunnable} from the {@link PriorityBlockingQueue}, only the delay time <= 0 can be consumed.
      */
     @SneakyThrows
     public ITaskExecutionRunnable takeTaskExecuteRunnable() {
-        ITaskExecutionRunnable taskExecutionRunnable = priorityQueue.take().getData();
+        ITaskExecutionRunnable taskExecutionRunnable = delayQueue.take().getData();
         while (!markTaskExecutionRunnableRemoved(taskExecutionRunnable)) {
-            taskExecutionRunnable = priorityQueue.take().getData();
+            taskExecutionRunnable = delayQueue.take().getData();
         }
         return taskExecutionRunnable;
     }