| | |
| | | package com.ruoyi.alarm.globalAlarm.domain; |
| | | |
| | | import lombok.extern.slf4j.Slf4j; |
| | | |
| | | import java.util.Comparator; |
| | | import java.util.HashMap; |
| | | import java.util.Map; |
| | | import java.util.PriorityQueue; |
| | | import java.util.concurrent.PriorityBlockingQueue; |
| | | |
| | | /** |
| | | * @Description: 引导优先级队列 |
| | |
| | | * @Date: 2023年06月29日11:18 |
| | | * @Version: 1.0 |
| | | **/ |
| | | @Slf4j |
| | | public class GuidePriorityQueue { |
| | | /** |
| | | * 相机队列,每个相机一个优先级队列 |
| | | */ |
| | | public static Map<String, PriorityQueue<GuideTask>> cameraQueueMap = new HashMap<>(); |
| | | public static Map<String, PriorityBlockingQueue<GuideTask>> cameraQueueMap = new HashMap<>(); |
| | | |
| | | /** |
| | | * 创建一个自定义的比较器,根据优先级属性进行比较 |
| | |
| | | return Comparator; |
| | | } |
| | | |
| | | /** |
| | | * 测试使用:打印队列 |
| | | */ |
| | | public static void printPriorityQueue() { |
| | | for (String cameraId : GuidePriorityQueue.cameraQueueMap.keySet()) { |
| | | PriorityBlockingQueue<GuideTask> priorityQueue = GuidePriorityQueue.cameraQueueMap.get(cameraId); |
| | | for (GuideTask task : priorityQueue) { |
| | | log.info("alarmId:" + task.getAlarmId() + " alarmTime:" + task.getAlarmTime() + " priority:" + task.getPriority() + " num:" + task.getNum() + " cameraId:" + task.getCameraId()); |
| | | } |
| | | } |
| | | } |
| | | } |