package com.project.util;

import com.project.common.core.domain.entity.SysUser;
import com.project.scoket.WebSocket;

import java.util.Map;
import java.util.concurrent.ConcurrentHashMap;

public class CurPoolUtil
{
    //    public static CopyOnWriteArraySet<WebSocket> webSockets =new CopyOnWriteArraySet<>();
    public static Map<Long, WebSocket> webSockets = new ConcurrentHashMap<>();
    // list 里面第一个存sessionId，第二个存session
    public static Map<Long, Object> sessionPool = new ConcurrentHashMap<>();
    // 当前登录用户x
    public static Map<String, SysUser> curUserPool = new ConcurrentHashMap<>();

}