package com.netsdk.demo.customize.surfaceEventDemo;
|
|
import java.util.*;
|
import java.util.concurrent.LinkedBlockingQueue;
|
import java.util.concurrent.locks.ReentrantReadWriteLock;
|
import java.util.stream.Collectors;
|
|
/**
|
* @author 47040
|
* @since Created in 2021/5/12 10:43
|
*/
|
public class EventResource {
|
|
/**
|
* 展示列表的最大长度
|
*/
|
private static final Integer MaxEventListSize = 50;
|
|
/**
|
* 用于在列表展示的事件列表，每次都插入到最前端
|
* <p>
|
* 最大长度随表格长度 超出后舍弃最旧的事件
|
*/
|
private static final List<SurfaceEventInfo> surfaceEventList = Collections.synchronizedList(new LinkedList<>());
|
|
/**
|
* 专门给展示列表用的读写锁
|
*/
|
private static final ReentrantReadWriteLock listLock = new ReentrantReadWriteLock();
|
|
/**
|
* 缓存的最大长度
|
*/
|
private static final Integer MaxEventCacheSize = 100;
|
|
/**
|
* 用于缓存所有事件 判断是否有可以组合成事件组的列表
|
* <p>
|
* 找到事件组后 取出这些事件并从列表中删除
|
*/
|
private static final List<SurfaceEventInfo> surfaceEventCache = Collections.synchronizedList(new LinkedList<>());
|
/**
|
* 专门给缓存用的读写锁
|
*/
|
private static final ReentrantReadWriteLock cacheLock = new ReentrantReadWriteLock();
|
|
/**
|
* 用于在存入事件列表和缓存后 触发监听器 的阻塞队列
|
* <p>
|
* 监听器在取到事件数据后 把它存入缓存的同时 判断是否有事件组
|
*/
|
private static final LinkedBlockingQueue<SurfaceEventInfo> surfaceEventQueue = new LinkedBlockingQueue<>(1000);
|
|
/**
|
* 用于事件list表界面展示 的阻塞队列
|
* <p>
|
* 这么做主要是为了当数据量大时，不会卡死 UI
|
*/
|
private static final LinkedBlockingQueue<List<SurfaceEventInfo>> surfaceEventListQueue = new LinkedBlockingQueue<>(1000);
|
|
/**
|
* 用于事件组界面展示 的阻塞队列
|
* <p>
|
* 这么做主要是为了当数据量大时有个缓存，不会卡死 UI
|
*/
|
private static final LinkedBlockingQueue<List<SurfaceEventInfo>> surfaceEventGroupQueue = new LinkedBlockingQueue<>(1000);
|
|
public static List<SurfaceEventInfo> getSurfaceEventList() {
|
return surfaceEventList;
|
}
|
|
public static List<SurfaceEventInfo> getSurfaceEventCache() {
|
return surfaceEventCache;
|
}
|
|
public static LinkedBlockingQueue<SurfaceEventInfo> getSurfaceEventQueue() {
|
return surfaceEventQueue;
|
}
|
|
public static LinkedBlockingQueue<List<SurfaceEventInfo>> getSurfaceEventListQueue() {
|
return surfaceEventListQueue;
|
}
|
|
public static LinkedBlockingQueue<List<SurfaceEventInfo>> getSurfaceEventGroupQueue() {
|
return surfaceEventGroupQueue;
|
}
|
|
// 给展示列表更新数据并添加到队列
|
public static void AddEventListEle(SurfaceEventInfo surfaceEventInfo) {
|
listLock.writeLock().lock();
|
|
getSurfaceEventList().add(0, surfaceEventInfo);
|
if (getSurfaceEventList().size() > MaxEventListSize) {
|
getSurfaceEventList().remove(MaxEventListSize.intValue());
|
}
|
|
// 浅拷贝一份推送到队列
|
getSurfaceEventListQueue().offer(new ArrayList<>(getSurfaceEventList()));
|
|
listLock.writeLock().unlock();
|
}
|
|
// 给缓存添加数据 并检查本事件组的事件是否都已收到 收到则添加到队列
|
public static void AddCacheAndCheckGroupEvents(SurfaceEventInfo surfaceEventInfo) {
|
|
cacheLock.writeLock().lock();
|
|
// 新事件添加进缓存
|
getSurfaceEventCache().add(surfaceEventInfo);
|
if (getSurfaceEventCache().size() > MaxEventCacheSize)
|
getSurfaceEventCache().remove(0);
|
|
Integer eventID = surfaceEventInfo.getEventID();
|
Integer count = surfaceEventInfo.getFileCount();
|
|
// 查找本 groupId 下的所有事件
|
List<SurfaceEventInfo> groupEvent = getSurfaceEventCache().stream()
|
.filter(e -> e.getEventID().equals(eventID)).collect(Collectors.toList());
|
|
// 该事件组内的事件已全部接受到
|
if (groupEvent.size() == count) {
|
// 排序后把事件组放进队列
|
groupEvent.sort(Comparator.comparingInt(o -> (Integer) o.getFileIndex()));
|
getSurfaceEventGroupQueue().offer(groupEvent);
|
// 从缓存里移除
|
getSurfaceEventCache().removeIf(e -> e.getEventID().equals(eventID));
|
}
|
|
cacheLock.writeLock().unlock();
|
}
|
|
/**
|
* 清空数据
|
*/
|
public static void clearAll(){
|
surfaceEventList.clear();
|
surfaceEventCache.clear();
|
surfaceEventQueue.clear();
|
surfaceEventListQueue.clear();
|
surfaceEventGroupQueue.clear();
|
}
|
}
|
