Using brute force to kill rogue threads created during Supervisor tests.

Author: jdantonio

spec/concurrent/supervisor_spec.rb

@@ -65,6 +65,7 @@ def stop() super(); stopped = true; end
 
     after(:each) do
       subject.stop
+      kill_rogue_threads
       sleep(0.1)
     end
 
@@ -846,7 +847,7 @@ def mock_thread(status = 'run')
           supervisor = Supervisor.new(restart_strategy: :one_for_one,
                                       monitor_interval: 0.1)
           supervisor.add_worker(error_class.new)
-          supervisor.should_receive(:exceeded_max_restart_frequency?).once.and_return(true)
+          supervisor.stub(:exceeded_max_restart_frequency?).once.and_return(true)
           future = Concurrent::Future.execute{ supervisor.run }
           future.value(1)
           supervisor.should_not be_running

spec/support/example_group_extensions.rb

@@ -26,6 +26,13 @@ def reset_gem_configuration
       Concurrent.instance_variable_set(:@configuration, Concurrent::Configuration.new)
     end
 
+    def kill_rogue_threads
+      warn '[DEPRECATED] brute force thread control being used -- tests need updated'
+      Thread.list.each do |thread|
+        thread.kill unless thread == Thread.current
+      end
+    end
+
     extend self
   end
 end