TimerSet now posts through Executor.

Author: jdantonio

lib/concurrent/executor/timer_set.rb

@@ -41,20 +41,12 @@ def initialize(opts = {})
     #
     # @raise [ArgumentError] if the intended execution time is not in the future
     # @raise [ArgumentError] if no block is given
-    def post(intended_time, &block)
-      mutex.synchronize do
-        return false unless running?
-        raise ArgumentError.new('no block given') unless block_given?
-        time = TimerSet.calculate_schedule_time(intended_time).to_f
-
-        if (time - Time.now.to_f) <= 0.01
-          @executor.post(&block)
-        else
-          @queue.push(Task.new(time, block))
-        end
+    def post(intended_time, &task)
+      time = TimerSet.calculate_schedule_time(intended_time).to_f
+      if super(time, &task)
+        check_processing_thread!
+        true
       end
-      check_processing_thread!
-      true
     end
 
     # Begin an orderly shutdown. Tasks already in the queue will be executed,
@@ -110,6 +102,14 @@ def <=>(other)
       end
     end
 
+    def execute(time, &task)
+      if (time - Time.now.to_f) <= 0.01
+        @executor.post(&task)
+      else
+        @queue.push(Task.new(time, task))
+      end
+    end
+
     # Check the status of the processing thread. This thread is responsible
     # for monitoring the internal task queue and sending tasks to the
     # executor when it is time for them to be processed. If there is no