lxy/redkale
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Browse Source
This commit is contained in:
地平线
2015-09-21 10:26:34 +08:00
parent 8285a02373
commit ed69bdc11b
1 changed files with 2 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
src/com/wentch/redkale/net/http/WebSocketEngine.java
View File

@@ -44,11 +44,9 @@ public final class WebSocketEngine {
t.setDaemon(true);
return t;
});
long now = System.currentTimeMillis() / 1000;
long delay = liveinterval - now / liveinterval;
scheduler.scheduleWithFixedDelay(() -> {
getWebSocketGroups().stream().forEach(x -> x.getWebSockets().forEach(y -> y.send(DEFAULT_PING_PACKET)));
}, delay, liveinterval, TimeUnit.SECONDS);
getWebSocketGroups().stream().forEach(x -> x.sendEach(DEFAULT_PING_PACKET));
}, (liveinterval - System.currentTimeMillis() / 1000 % liveinterval), liveinterval, TimeUnit.SECONDS);
if (finest) logger.finest(this.getClass().getSimpleName() + "(" + engineid + ")" + " start keeplive(interval:" + liveinterval + "s) scheduler executor");
}