back_recharge
parent
e98d7b482b
commit
cf05efb0da
|
@ -64,13 +64,14 @@ public class UserManager {
|
||||||
//离线清除逻辑
|
//离线清除逻辑
|
||||||
public static void checkOffline(){
|
public static void checkOffline(){
|
||||||
try {
|
try {
|
||||||
|
long linshitime = 10 * 60 * 1000L;
|
||||||
Set<User> collect = userMap.entrySet().stream()
|
Set<User> collect = userMap.entrySet().stream()
|
||||||
.filter(integerUserEntry -> !OnlineUserManager.checkUidOnline(integerUserEntry.getKey()))
|
.filter(integerUserEntry -> !OnlineUserManager.checkUidOnline(integerUserEntry.getKey()))
|
||||||
.map(Map.Entry::getValue).collect(Collectors.toSet());
|
.map(Map.Entry::getValue).collect(Collectors.toSet());
|
||||||
long now = System.currentTimeMillis();
|
long now = System.currentTimeMillis();
|
||||||
for (User integerUserEntry : collect) {
|
for (User integerUserEntry : collect) {
|
||||||
Long addTime = userMapPutTime.getOrDefault(integerUserEntry.getId(), LIVE_TIME);
|
Long addTime = userMapPutTime.getOrDefault(integerUserEntry.getId(), linshitime);
|
||||||
if (now - addTime >= LIVE_TIME) {
|
if (now - addTime >= linshitime) {
|
||||||
userMap.remove(integerUserEntry.getId());
|
userMap.remove(integerUserEntry.getId());
|
||||||
userMapPutTime.remove(integerUserEntry.getId());
|
userMapPutTime.remove(integerUserEntry.getId());
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in New Issue