class Concurrent::RubySingleThreadExecutor

def work
  loop do
    task = @queue.pop
    break if task == :stop
    begin
      task.last.call(*task.first)
    rescue => ex
      # let it fail
    end
  end
  stopped_event.set
end