модуль Timeout

# File lib/timeout.rb, line 167
def timeout(sec, klass = nil, message = nil, &block)   #:yield: +sec+
  return yield(sec) if sec == nil or sec.zero?
  raise ArgumentError, "Timeout sec must be a non-negative number" if 0 > sec

  message ||= "execution expired"

  if Fiber.respond_to?(:current_scheduler) && (scheduler = Fiber.current_scheduler)&.respond_to?(:timeout_after)
    return scheduler.timeout_after(sec, klass || Error, message, &block)
  end

  Timeout.ensure_timeout_thread_created
  perform = Proc.new do |exc|
    request = Request.new(Thread.current, sec, exc, message)
    QUEUE_MUTEX.synchronize do
      QUEUE << request
      CONDVAR.signal
    end
    begin
      return yield(sec)
    ensure
      request.finished
    end
  end

  if klass
    perform.call(klass)
  else
    Error.handle_timeout(message, &perform)
  end
end

Выполняет операцию в блоке, вызывая ошибку, если выполнение занимает более sec секунд.

sec

Количество секунд ожидания завершения блока. Можно использовать любое неотрицательное число или nil, включая числа с плавающей запятой для указания дробных секунд. Значение 0 или nil выполнит блок без таймаута. Любое отрицательное число вызовет ArgumentError.

klass

Exception Class для вызова, если блок не завершился в течение sec секунд. Если опущено, будет использоваться значение по умолчанию: Timeout::Error.

message

Error сообщение для вызова с Exception Class. Если опущено, будет использоваться значение по умолчанию: «истечение времени выполнения»

Возвращает результат блока, если блок завершился до sec секунд, в противном случае генерирует исключение, в зависимости от значения klass.

Исключение, вызываемое для завершения данного блока, нельзя перехватить внутри блока, если явно не указано klass. Однако, блок может использовать ensure для предотвращения обработки исключения. По этой причине этот метод нельзя использовать для принудительного таймаута недоверенных блоков.

Если задан планировщик, он будет использован для обработки таймаута, вызвав Scheduler#timeout_after.

Обратите внимание, что это метод модуля Timeout, поэтому вы можете include Timeout в свои классы, чтобы они имели метод timeout, а также метод модуля, чтобы вызвать его напрямую как Timeout.timeout().

# File lib/timeout.rb, line 167
def timeout(sec, klass = nil, message = nil, &block)   #:yield: +sec+
  return yield(sec) if sec == nil or sec.zero?
  raise ArgumentError, "Timeout sec must be a non-negative number" if 0 > sec

  message ||= "execution expired"

  if Fiber.respond_to?(:current_scheduler) && (scheduler = Fiber.current_scheduler)&.respond_to?(:timeout_after)
    return scheduler.timeout_after(sec, klass || Error, message, &block)
  end

  Timeout.ensure_timeout_thread_created
  perform = Proc.new do |exc|
    request = Request.new(Thread.current, sec, exc, message)
    QUEUE_MUTEX.synchronize do
      QUEUE << request
      CONDVAR.signal
    end
    begin
      return yield(sec)
    ensure
      request.finished
    end
  end

  if klass
    perform.call(klass)
  else
    Error.handle_timeout(message, &perform)
  end
end

Выполняет операцию в блоке, вызывая ошибку, если выполнение занимает более sec секунд.

sec

Количество секунд ожидания завершения блока. Можно использовать любое неотрицательное число или nil, включая числа с плавающей запятой для указания дробных секунд. Значение 0 или nil выполнит блок без таймаута. Любое отрицательное число вызовет ArgumentError.

klass

Exception Class для вызова, если блок не завершился в течение sec секунд. Если опущено, будет использоваться значение по умолчанию: Timeout::Error.

message

Error сообщение для вызова с Exception Class. Если опущено, будет использоваться значение по умолчанию: «истечение времени выполнения»

Возвращает результат блока, если блок завершился до sec секунд, в противном случае генерирует исключение, в зависимости от значения klass.

Исключение, вызываемое для завершения данного блока, нельзя перехватить внутри блока, если явно не указано klass. Однако, блок может использовать ensure для предотвращения обработки исключения. По этой причине этот метод нельзя использовать для принудительного таймаута недоверенных блоков.

Если задан планировщик, он будет использован для обработки таймаута, вызвав Scheduler#timeout_after.

Обратите внимание, что это метод модуля Timeout, поэтому вы можете include Timeout в свои классы, чтобы они имели метод timeout, а также метод модуля, чтобы вызвать его напрямую как Timeout.timeout().