| | |
|---|
| | | |
|---|
| | | //创建引导队列 |
|---|
| | | private void createGuideQueue(ArdCameras camera) { |
|---|
| | | if (camera.getCamAlarmGuideEnable() != null) { |
|---|
| | | if (camera.getCamAlarmGuideEnable() == 1) { |
|---|
| | | if (!GuidePriorityQueue.cameraQueueMap.containsKey(camera.getId())) { |
|---|
| | | Comparator<GuideTask> comparator = GuidePriorityQueue.getComparator(); |
|---|
| | | PriorityBlockingQueue<GuideTask> priorityQueue = new PriorityBlockingQueue<>(1000, comparator); |
|---|
| | | GuidePriorityQueue.cameraQueueMap.put(camera.getId(), priorityQueue); |
|---|
| | | //启动队列处理器 |
|---|
| | | queueHandler.process(camera.getId()); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | if (!GuidePriorityQueue.cameraQueueMap.containsKey(camera.getId())) { |
|---|
| | | Comparator<GuideTask> comparator = GuidePriorityQueue.getComparator(); |
|---|
| | | PriorityBlockingQueue<GuideTask> priorityQueue = new PriorityBlockingQueue<>(1000, comparator); |
|---|
| | | GuidePriorityQueue.cameraQueueMap.put(camera.getId(), priorityQueue); |
|---|
| | | //启动队列处理器 |
|---|
| | | queueHandler.process(camera.getId()); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | |
|---|
