Skip to content

Commit fbc29a0

Browse files
committed
The smaller the timestamp, the first to execute
1 parent 5ee10e8 commit fbc29a0

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

platform-queue/src/main/java/com/flow/platform/queue/PriorityQueueItem.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -38,7 +38,7 @@ class ItemComparator implements Comparator<PriorityQueueItem> {
3838
@Override
3939
public int compare(PriorityQueueItem o1, PriorityQueueItem o2) {
4040
if (Objects.equals(o1.getPriority(), o2.getPriority())) {
41-
return o2.getTimestamp().compareTo(o1.getTimestamp());
41+
return o1.getTimestamp().compareTo(o2.getTimestamp());
4242
}
4343

4444
return o2.getPriority().compareTo(o1.getPriority());

0 commit comments

Comments
 (0)