Updated brittle Supervisor #count#stopped spec.

Author: jdantonio

spec/concurrent/supervisor_spec.rb

@@ -23,8 +23,16 @@ def run() super(); sleep; end
 
     let(:stopper_class) do
       Class.new(worker_class) {
-        def initialize(sleep_time = 0.2) @sleep_time = sleep_time; end;
-        def run() super(); sleep(@sleep_time); end
+        attr_reader :latch
+        def initialize(sleep_time = 0.2)
+          @sleep_time = sleep_time
+          @latch = Concurrent::CountDownLatch.new(1)
+        end
+        def run
+          super
+          sleep(@sleep_time)
+          @latch.count_down
+        end
       }
     end
 
@@ -326,13 +334,18 @@ def mock_thread(status = 'run')
 
     context '#count' do
 
+      let(:stoppers){ Array.new }
+
       let(:busy_supervisor) do
         supervisor = Supervisor.new(monitor_interval: 60)
         3.times do
           supervisor.add_worker(sleeper_class.new)
-          supervisor.add_worker(stopper_class.new)
           supervisor.add_worker(error_class.new)
           supervisor.add_worker(runner_class.new)
+
+          stopper = stopper_class.new
+          stoppers << stopper
+          supervisor.add_worker(stopper)
         end
         supervisor
       end
@@ -426,7 +439,7 @@ def mock_thread(status = 'run')
       it 'returns the count of all stopped workers as #stopped' do
         busy_supervisor.count.stopped.should eq total_count
         busy_supervisor.run!
-        sleep(0.5)
+        stoppers.each{|stopper| stopper.latch.wait(1) }
 
         busy_supervisor.count.stopped.should eq stopped_count
       end