liusuyi
2023-06-29 3daa378637a5ceeb4965b554f528a7a36e3d5c2a
ard-work/src/main/java/com/ruoyi/alarm/globalAlarm/domain/GuidePriorityQueue.java
@@ -1,23 +1,26 @@
package com.ruoyi.alarm.globalAlarm.domain;
import com.ruoyi.alarm.globalAlarm.service.impl.GuideTask;
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:
 * @Description: 引导优先级队列
 * @ClassName: PriorityQueue
 * @Author: 刘苏义
 * @Date: 2023年06月29日11:18
 * @Version: 1.0
 **/
@Slf4j
public class GuidePriorityQueue {
    /**
     * 相机队列,每个相机一个优先级队列
     */
    public static Map<String, java.util.PriorityQueue<GuideTask>> cameraQueueMap = new HashMap<>();
    public static Map<String, PriorityBlockingQueue<GuideTask>> cameraQueueMap = new HashMap<>();
    /**
     * 创建一个自定义的比较器,根据优先级属性进行比较
@@ -30,4 +33,15 @@
        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());
            }
        }
    }
}