Add daemon thread factory for SingleThreadExecutor

Author: fzakaria

lib/concurrent-ruby/concurrent/executor/java_executor_service.rb

@@ -81,5 +81,21 @@ def run
       end
       private_constant :Job
     end
+
+    class DaemonThreadFactory
+      # hide include from YARD
+      send :include, java.util.concurrent.ThreadFactory
+
+      def initialize(daemonize = true)
+        @daemonize = daemonize
+      end
+
+      def newThread(runnable)
+        thread = java.util.concurrent.Executors.defaultThreadFactory().newThread(runnable)
+        thread.setDaemon(@daemonize)
+        return thread
+      end
+    end
+    
   end
 end

lib/concurrent-ruby/concurrent/executor/java_single_thread_executor.rb

@@ -19,7 +19,9 @@ def initialize(opts = {})
       private
 
       def ns_initialize(opts)
-        @executor = java.util.concurrent.Executors.newSingleThreadExecutor
+        @executor = java.util.concurrent.Executors.newSingleThreadExecutor(
+            DaemonThreadFactory.new(ns_auto_terminate?)
+        )
         @fallback_policy = opts.fetch(:fallback_policy, :discard)
         raise ArgumentError.new("#{@fallback_policy} is not a valid fallback policy") unless FALLBACK_POLICY_CLASSES.keys.include?(@fallback_policy)
       end

lib/concurrent-ruby/concurrent/executor/java_thread_pool_executor.rb

@@ -108,6 +108,8 @@ def ns_initialize(opts)
           queue = java.util.concurrent.LinkedBlockingQueue.new(@max_queue)
         end
 
+        self.auto_terminate = opts.fetch(:auto_terminate, true)
+
         @executor = java.util.concurrent.ThreadPoolExecutor.new(
             min_length,
             max_length,
@@ -120,21 +122,5 @@ def ns_initialize(opts)
       end
     end
 
-    class DaemonThreadFactory
-      # hide include from YARD
-      send :include, java.util.concurrent.ThreadFactory
-
-      def initialize(daemonize = true)
-        @daemonize = daemonize
-      end
-
-      def newThread(runnable)
-        thread = java.util.concurrent.Executors.defaultThreadFactory().newThread(runnable)
-        thread.setDaemon(@daemonize)
-        return thread
-      end
-    end
-
-    private_constant :DaemonThreadFactory
   end
 end