Smartcraft-Media-Tech/TikTokLiveJava
1
0
Fork 0
mirror of https://github.com/jwdeveloper/TikTokLiveJava.git synced 2026-02-27 08:49:40 -05:00
Code Issues Packages Projects Releases Wiki Activity

Add static to fields for single instance to manage all heartbeat threads. Far more efficient than 1 thread each sleeping!

Browse Source
This commit is contained in:
kohlerpop1
2025-09-04 22:01:40 -04:00
parent 646e4c68ab
commit 9c75abc80f
1 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
Client/src/main/java/io/github/jwdeveloper/tiktok/websocket/WebSocketHeartbeatTask.java
View File

@@ -30,13 +30,13 @@ import java.util.concurrent.*;
public class WebSocketHeartbeatTask public class WebSocketHeartbeatTask
{ {
// Single shared pool for all heartbeat tasks // Single shared pool for all heartbeat tasks
private final ScheduledExecutorService scheduler = Executors.newScheduledThreadPool(1, r -> { private static final ScheduledExecutorService scheduler = Executors.newScheduledThreadPool(1, r -> {
Thread t = new Thread(r, "heartbeat-pool"); Thread t = new Thread(r, "heartbeat-pool");
t.setDaemon(true); t.setDaemon(true);
return t; return t;
}); });
private final Map<WebSocket, ScheduledFuture<?>> tasks = new ConcurrentHashMap<>(); private static final Map<WebSocket, ScheduledFuture<?>> tasks = new ConcurrentHashMap<>();
private final Map<WebSocket, Long> commTime = new ConcurrentHashMap<>(); private static final Map<WebSocket, Long> commTime = new ConcurrentHashMap<>();
private final byte[] heartbeatBytes = Base64.getDecoder().decode("MgJwYjoCaGI="); // Used to be '3A026862' aka ':\x02hb', now is '2\x02pb:\x02hb'. private final byte[] heartbeatBytes = Base64.getDecoder().decode("MgJwYjoCaGI="); // Used to be '3A026862' aka ':\x02hb', now is '2\x02pb:\x02hb'.