feat(nats-connection): implement named executor thread factories

nats-io · Nov 20, 2024 · 66a1fde · 66a1fde
1 parent 2175501
commit 66a1fde
Showing 1 changed file with 16 additions and 2 deletions.
diff --git a/src/main/java/io/nats/client/impl/NatsConnection.java b/src/main/java/io/nats/client/impl/NatsConnection.java
@@ -157,8 +157,22 @@ class NatsConnection implements Connection {
 
         timeTraceLogger.trace("creating executors");
         this.executor = options.getExecutor();
-        this.callbackRunner = Executors.newSingleThreadExecutor();
-        this.connectExecutor = Executors.newSingleThreadExecutor();
+        this.callbackRunner = Executors.newSingleThreadExecutor(new ThreadFactory() {
+            @Override
+            public Thread newThread(Runnable r) {
+                Thread t = new Thread(r);
+                t.setName("nats-callback-runner");
+                return t;
+            }
+        });
+        this.connectExecutor = Executors.newSingleThreadExecutor(new ThreadFactory() {
+            @Override
+            public Thread newThread(Runnable r) {
+                Thread t = new Thread(r);
+                t.setName("nats-connect-executor");
+                return t;
+            }
+        });
 
         timeTraceLogger.trace("creating reader and writer");
         this.reader = new NatsConnectionReader(this);