package com.ruoyi.alarm.global.domain;
|
|
import lombok.extern.slf4j.Slf4j;
|
|
import java.util.*;
|
import java.util.concurrent.PriorityBlockingQueue;
|
|
/**
|
* @Description: 引导优先级队列
|
* @ClassName: PriorityQueue
|
* @Author: 刘苏义
|
* @Date: 2023年06月29日11:18
|
* @Version: 1.0
|
**/
|
@Slf4j(topic = "guideQueue")
|
public class GuidePriorityQueue {
|
/**
|
* 相机队列，每个相机一个优先级队列
|
*/
|
public static Map<String, PriorityBlockingQueue<GuideTask>> cameraQueueMap = new HashMap<>();
|
|
/**
|
* 创建一个自定义的比较器，根据优先级属性进行比较
|
*/
|
public static Comparator<GuideTask> getComparator() {
|
Comparator<GuideTask> PriorityDescCom = Comparator.comparingInt(GuideTask::getPriority).reversed();
|
Comparator<GuideTask> receiveTimeAscCom = Comparator.comparing(GuideTask::getReceiveTime);
|
Comparator<GuideTask> Comparator = PriorityDescCom.thenComparing(receiveTimeAscCom);
|
return Comparator;
|
}
|
|
/**
|
* 测试使用：打印队列
|
*/
|
public static void printPriorityQueue() {
|
for (String cameraId : GuidePriorityQueue.cameraQueueMap.keySet()) {
|
PriorityBlockingQueue<GuideTask> priorityQueue = GuidePriorityQueue.cameraQueueMap.get(cameraId);
|
PriorityBlockingQueue<GuideTask> queue = new PriorityBlockingQueue<>(priorityQueue);
|
while (queue.size() > 0) {
|
GuideTask task = queue.poll();
|
log.info("正在排队【cameraId】" + task.getCameraId() + "【alarmId】" + task.getAlarmId() + "【receiveTime】" + task.getReceiveTime()
|
+ "【alarmType】" + task.getAlarmType() + "【priority】" + task.getPriority() + "【chanNo】" + task.getChanNo());
|
}
|
}
|
}
|
}
|
