ScheduledTask now uses CopyOnNotifyObserverSet.

Author: jdantonio

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