class Concurrent::RubyThreadPoolExecutor

def handle_overflow(*args)
  case @overflow_policy
  when :abort
    raise RejectedExecutionError
  when :discard
    false
  when :caller_runs
    begin
      yield(*args)
    rescue
      # let it fail
    end
    true
  end
end