natas_hw
/
dolphinscheduler
0
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Rename variable QUEUE_MAX_SIZE to QUEUE_INITIAL_SIZE (#16040)

This commit is contained in:
sleo 2024-05-24 20:09:10 +08:00 committed by GitHub
parent f754611509
commit 26f2aadb06
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 1 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
dolphinscheduler-service/src/main/java/org/apache/dolphinscheduler/service/queue/StandByTaskInstancePriorityQueue.java
View File

@ -36,16 +36,10 @@ import com.google.common.base.Preconditions;
*/ */
public class StandByTaskInstancePriorityQueue implements TaskPriorityQueue<TaskInstance> { public class StandByTaskInstancePriorityQueue implements TaskPriorityQueue<TaskInstance> {
/**
* queue size
*/
private static final Integer QUEUE_MAX_SIZE = 3000;
/** /**
* queue * queue
*/ */
private final PriorityQueue<TaskInstance> queue = private final PriorityQueue<TaskInstance> queue = new PriorityQueue<>(new TaskInstancePriorityComparator());
new PriorityQueue<>(QUEUE_MAX_SIZE, new TaskInstancePriorityComparator());
private final Set<String> taskInstanceIdentifySet = Collections.synchronizedSet(new HashSet<>()); private final Set<String> taskInstanceIdentifySet = Collections.synchronizedSet(new HashSet<>());
/** /**