| | |
| | | */ |
| | | public static Comparator<GuideTask> getComparator() { |
| | | Comparator<GuideTask> PriorityDescCom = Comparator.comparingInt(GuideTask::getPriority).reversed(); |
| | | Comparator<GuideTask> NumDescCom = Comparator.comparingInt(GuideTask::getNum).reversed(); |
| | | Comparator<GuideTask> receiveTimeAscCom = Comparator.comparing(GuideTask::getReceiveTime); |
| | | Comparator<GuideTask> Comparator = PriorityDescCom.thenComparing(NumDescCom).thenComparing(receiveTimeAscCom); |
| | | Comparator<GuideTask> Comparator = PriorityDescCom.thenComparing(receiveTimeAscCom); |
| | | return Comparator; |
| | | } |
| | | |
| | |
| | | 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() + "【num】" + task.getNum() |
| | | + "【chan】" + task.getChanNum() + "【recordSn】" + task.getRecordSn()); |
| | | log.info("正在排队【cameraId】" + task.getCameraId() + "【alarmId】" + task.getAlarmId() + "【receiveTime】" + task.getReceiveTime() |
| | | + "【alarmType】" + task.getAlarmType() + "【priority】" + task.getPriority() + "【chanNo】" + task.getChanNo()); |
| | | } |
| | | } |
| | | } |