Timers now pass options to the task blocks (untested).

Author: jdantonio

lib/concurrent/executor/timer_set.rb

@@ -42,17 +42,17 @@ 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, &task)
+    def post(intended_time, *args, &task)
       time = TimerSet.calculate_schedule_time(intended_time).to_f
       raise ArgumentError.new('no block given') unless block_given?
 
       mutex.synchronize do
         return false unless running?
 
         if (time - Time.now.to_f) <= 0.01
-          @executor.post(&task)
+          @executor.post(*args, &task)
         else
-          @queue.push(Task.new(time, task))
+          @queue.push(Task.new(time, args, task))
           check_processing_thread!
         end
 
@@ -94,7 +94,7 @@ def self.calculate_schedule_time(intended_time, now = Time.now)
     # times.
     #
     # @!visibility private
-    Task = Struct.new(:time, :op) do
+    Task = Struct.new(:time, :args, :op) do
       include Comparable
 
       def <=>(other)
@@ -137,7 +137,6 @@ def check_processing_thread!
     # @!visibility private
     def process_tasks
       loop do
-
         mutex.synchronize do
           if @queue.empty?
             @thread = nil
@@ -148,7 +147,7 @@ def process_tasks
           interval = task.time - Time.now.to_f
 
           if interval <= 0
-            @executor.post(&task.op)
+            @executor.post(*task.args, &task.op)
             @queue.pop
           else
             @condition.wait(mutex, [interval, 60].min)

lib/concurrent/utility/timer.rb

@@ -10,11 +10,11 @@ module Concurrent
   # @yield the task to execute
   #
   # @return [Boolean] true
-  def timer(seconds, &block)
+  def timer(seconds, *args, &block)
     raise ArgumentError.new('no block given') unless block_given?
     raise ArgumentError.new('interval must be greater than or equal to zero') if seconds < 0
 
-    Concurrent.configuration.global_timer_set.post(seconds, &block)
+    Concurrent.configuration.global_timer_set.post(seconds, *args, &block)
     true
   end
   module_function :timer

spec/concurrent/executor/timer_set_spec.rb

@@ -35,6 +35,8 @@ module Concurrent
       latch.wait(0.2).should be_true
     end
 
+    it 'passes all areguments to the task on execution'
+
     it 'immediately posts a task when the delay is zero' do
       Thread.should_not_receive(:new).with(any_args)
       subject.post(0){ true }

spec/concurrent/utility/timer_spec.rb

@@ -33,6 +33,8 @@ module Concurrent
       }.to_not raise_error
     end
 
+    it 'passes all arguments to the block'
+
     it 'runs the task on the global timer pool' do
       Concurrent.configuration.global_timer_set.should_receive(:post).with(0.1)
       Concurrent::timer(0.1){ :foo }