class Concurrent::ImmediateExecutor

def <<(task)
  post(&task)
  self
end

def post(*args, &task)
  raise ArgumentError.new('no block given') unless block_given?
  task.call(*args)
  true
end