aijinhui
2023-12-14 af3b68eeca07a30967754dc1a61b8def9efe188c
ard-work/src/main/java/com/ruoyi/alarm/global/service/impl/QueueHandler.java
@@ -71,9 +71,9 @@
        //    newThread.start();
        //}
    }
    @Async
    @Async("guideExecutor")
    public void process(String cameraId) {
        log.debug("CameraId:【" + cameraId + "】队列处理器启动");
        log.debug("CameraId:【" + cameraId + "】引导队列处理器启动成功");
        PriorityBlockingQueue<GuideTask> guideTasks = GuidePriorityQueue.cameraQueueMap.get(cameraId);
        while (true) {
            if (guideTasks.size() > 0) {