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> cameraQueueMap = new HashMap<>(); /** * 创建一个自定义的比较器,根据优先级属性进行比较 */ public static Comparator getComparator() { Comparator PriorityDescCom = Comparator.comparingInt(GuideTask::getPriority).reversed(); Comparator receiveTimeAscCom = Comparator.comparing(GuideTask::getReceiveTime); Comparator Comparator = PriorityDescCom.thenComparing(receiveTimeAscCom); return Comparator; } /** * 测试使用:打印队列 */ public static void printPriorityQueue() { for (String cameraId : GuidePriorityQueue.cameraQueueMap.keySet()) { PriorityBlockingQueue priorityQueue = GuidePriorityQueue.cameraQueueMap.get(cameraId); PriorityBlockingQueue 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()); } } } }