Call kill directly b/c running will be false and won't make it there

brandonhilkert · Aug 12, 2017 · 54433b8 · 54433b8
1 parent b91bc22
commit 54433b8
Showing 1 changed file with 6 additions and 8 deletions.
diff --git a/lib/sucker_punch/queue.rb b/lib/sucker_punch/queue.rb
@@ -52,13 +52,13 @@ def self.stats
         queues[queue.name] = {
           "workers" => {
             "total" => queue.total_workers,
-            "busy" => queue.busy_workers,
-            "idle" => queue.idle_workers,
+            "busy"  => queue.busy_workers,
+            "idle"  => queue.idle_workers,
           },
           "jobs" => {
             "processed" => queue.processed_jobs,
-            "failed" => queue.failed_jobs,
-            "enqueued" => queue.enqueued_jobs,
+            "failed"    => queue.failed_jobs,
+            "enqueued"  => queue.enqueued_jobs,
           }
         }
       end
@@ -70,7 +70,7 @@ def self.shutdown_all
       if SuckerPunch::RUNNING.make_false
 
         queues = all
-        latch = Concurrent::CountDownLatch.new(queues.length)
+        latch  = Concurrent::CountDownLatch.new(queues.length)
 
         queues.each do |queue|
           queue.post(latch) { |l| l.count_down }
@@ -146,9 +146,7 @@ def post(*args, &block)
     end
 
     def kill
-      if can_initiate_shutdown?
-        @pool.kill
-      end
+      @pool.kill
     end
 
     def shutdown