модуль Timeout

# File lib/timeout.rb, line 169
def timeout(sec, klass = nil, message = nil, &block)   #:yield: +sec+
  return yield(sec) if sec == nil or sec.zero?

  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

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

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 169
def timeout(sec, klass = nil, message = nil, &block)   #:yield: +sec+
  return yield(sec) if sec == nil or sec.zero?

  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

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

klass

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

message

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

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

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

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

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