inlined a couple of methods

Author: mighe

lib/concurrent/executor/timer_set.rb

@@ -43,10 +43,21 @@ def initialize(opts = {})
     # @raise [ArgumentError] if no block is given
     def post(intended_time, &task)
       time = TimerSet.calculate_schedule_time(intended_time).to_f
-      if super(time, &task)
-        check_processing_thread!
+      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)
+        else
+          @queue.push(Task.new(time, task))
+          check_processing_thread!
+        end
+
         true
       end
+
     end
 
     alias_method :kill, :shutdown
@@ -84,20 +95,12 @@ def self.calculate_schedule_time(intended_time, now = Time.now)
     # @!visibility private
     Task = Struct.new(:time, :op) do
       include Comparable
+
       def <=>(other)
         self.time <=> other.time
       end
     end
 
-    # @!visibility private
-    def execute(time, &task)
-      if (time - Time.now.to_f) <= 0.01
-        @executor.post(&task)
-      else
-        @queue.push(Task.new(time, task))
-      end
-    end
-
     # @!visibility private
     def shutdown_execution
       @queue.clear
@@ -114,15 +117,13 @@ def shutdown_execution
     #
     # @!visibility private
     def check_processing_thread!
-      mutex.synchronize do
-        return if shutdown? || @queue.empty?
-        if @thread && @thread.status == 'sleep'
-          @thread.wakeup
-        elsif @thread.nil? || ! @thread.alive?
-          @thread = Thread.new do
-            Thread.current.abort_on_exception = true
-            process_tasks
-          end
+      return if shutdown? || @queue.empty?
+      if @thread && @thread.status == 'sleep'
+        @thread.wakeup
+      elsif @thread.nil? || !@thread.alive?
+        @thread = Thread.new do
+          Thread.current.abort_on_exception = true
+          process_tasks
         end
       end
     end