Skip to content

Commit 9e4c1ce

Browse files
committed
Added WSKeepAliveThread
1 parent 68df48e commit 9e4c1ce

File tree

1 file changed

+34
-0
lines changed

1 file changed

+34
-0
lines changed
Lines changed: 34 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,34 @@
1+
package dev.latvian.apps.tinyserver.ws;
2+
3+
import dev.latvian.apps.tinyserver.HTTPServer;
4+
5+
public class WSKeepAliveThread extends Thread {
6+
public final HTTPServer<?> server;
7+
public final WSHandler<?, ?> handler;
8+
9+
public WSKeepAliveThread(HTTPServer<?> server, WSHandler<?, ?> handler, String name) {
10+
super("WSKeepAliveThread-" + name);
11+
this.server = server;
12+
this.handler = handler;
13+
setDaemon(true);
14+
}
15+
16+
@Override
17+
public void run() {
18+
while (server.isRunning()) {
19+
try {
20+
for (var session : handler) {
21+
session.sendPing(new byte[0]);
22+
}
23+
} catch (Exception ex) {
24+
ex.printStackTrace();
25+
}
26+
27+
try {
28+
Thread.sleep(10000L);
29+
} catch (Exception ex) {
30+
ex.printStackTrace();
31+
}
32+
}
33+
}
34+
}

0 commit comments

Comments
 (0)