ReactiveX#351 - this change should fix bug that prevents JVM shutdown

jihoonson · Mar 6, 2019 · c458153 · c458153
1 parent 347c302
commit c458153
Showing 1 changed file with 10 additions and 3 deletions.
diff --git a/...reaker/src/main/java/io/github/resilience4j/circuitbreaker/internal/AutoTransitioner.java b/...reaker/src/main/java/io/github/resilience4j/circuitbreaker/internal/AutoTransitioner.java
@@ -13,8 +13,7 @@
  */
 public class AutoTransitioner {
 
-    private static final Lazy<ScheduledExecutorService> executorService = Lazy.of(
-            Executors::newSingleThreadScheduledExecutor);
+    private static final Lazy<ScheduledExecutorService> executorService = Lazy.of(AutoTransitioner::autoTransitionerSchedulerFactory);
 
     private AutoTransitioner() {
     }
@@ -25,4 +24,12 @@ public static void scheduleAutoTransition(Runnable transition, Duration waitDura
                 waitDurationInOpenState.toMillis(),
                 TimeUnit.MILLISECONDS);
     }
-}
+
+    private static ScheduledExecutorService autoTransitionerSchedulerFactory() {
+        return Executors.newSingleThreadScheduledExecutor(threadTask -> {
+            Thread thread = new Thread(threadTask, "AutomaticTransitionerFromOpenToHalfOpen");
+            thread.setDaemon(true);
+            return thread;
+        });
+    }
+}