| | |
| | | import javax.annotation.Resource; |
| | | import java.util.Comparator; |
| | | import java.util.PriorityQueue; |
| | | import java.util.concurrent.PriorityBlockingQueue; |
| | | |
| | | /** |
| | | * @Description: 异步登录回调 |
| | |
| | | public class LoginResultCallBack implements HCNetSDK.FLoginResultCallBack { |
| | | |
| | | private ArdCameras camera; |
| | | |
| | | public LoginResultCallBack(ArdCameras camera) { |
| | | this.camera = camera; |
| | | } |
| | |
| | | camera.setChannel((int) lpDeviceinfo.byChanNum); |
| | | //创建引导队列 |
| | | Comparator<GuideTask> comparator = GuidePriorityQueue.getComparator(); |
| | | PriorityQueue<GuideTask> priorityQueue=new PriorityQueue<>(comparator); |
| | | PriorityBlockingQueue<GuideTask> priorityQueue = new PriorityBlockingQueue<>(1000,comparator); |
| | | GuidePriorityQueue.cameraQueueMap.put(camera.getId(),priorityQueue); |
| | | } else { |
| | | log.info(camera.getIp() + ":" + camera.getPort() + "登录失败"); |