ScheduledTask now uses CopyOnNotifyObserverSet.

jdantonio · jdantonio · commit 3efbe2917f0f · 2014-04-15T07:10:19.000-04:00
diff --git a/lib/concurrent/scheduled_task.rb b/lib/concurrent/scheduled_task.rb
@@ -14,6 +14,7 @@ def initialize(intended_time, opts = {}, &block)
 
       super(NO_VALUE, opts)
 
+      self.observers = CopyOnNotifyObserverSet.new
       @intended_time =  intended_time
       @state = :unscheduled
       @task = block
