h4ckx0r/engine.io-client-java
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

feat: create heartbeat scheduler with named threads and as daemon (#106)

Browse Source 
Co-authored-by: Pavel Valodzka <pavel@valodzka.name>
This commit is contained in:
valodzka
2021-01-22 12:41:06 +03:00
committed by GitHub
parent 686ac08a6e
commit 7c9c382505
1 changed files with 17 additions and 11 deletions
Download Patch File Download Diff File Expand all files Collapse all files

28
src/main/java/io/socket/engineio/client/Socket.java
View File

@@ -4,16 +4,9 @@ import org.json.JSONException;
import java.net.URI;
import java.net.URISyntaxException;
import java.util.ArrayList;
import java.util.Arrays;
import java.util.HashMap;
import java.util.LinkedList;
import java.util.List;
import java.util.Map;
import java.util.concurrent.Executors;
import java.util.concurrent.Future;
import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.TimeUnit;
import java.util.*;
import java.util.concurrent.*;
import java.util.concurrent.atomic.AtomicInteger;
import java.util.logging.Level;
import java.util.logging.Logger;
@@ -37,6 +30,8 @@ public class Socket extends Emitter {
private static final Logger logger = Logger.getLogger(Socket.class.getName());
private static final AtomicInteger HEARTBEAT_THREAD_COUNTER = new AtomicInteger();
private static final String PROBE_ERROR = "probe error";
@@ -848,11 +843,22 @@ public class Socket extends Emitter {
private ScheduledExecutorService getHeartbeatScheduler() {
if (this.heartbeatScheduler == null || this.heartbeatScheduler.isShutdown()) {
this.heartbeatScheduler = Executors.newSingleThreadScheduledExecutor();
this.heartbeatScheduler = createHeartbeatScheduler();
}
return this.heartbeatScheduler;
}
private ScheduledExecutorService createHeartbeatScheduler() {
return Executors.newSingleThreadScheduledExecutor(new ThreadFactory() {
@Override
public Thread newThread(Runnable r) {
Thread thread = new Thread(r, "engine.io-client.heartbeat-" + HEARTBEAT_THREAD_COUNTER.getAndIncrement());
thread.setDaemon(true);
return thread;
}
});
}
public static class Options extends Transport.Options {
/**