File Manager

X7ROOT File Manager

Current Path: /opt/alt/ruby33/share/ruby

ðŸ“ ..
ðŸ“„ English.rb(5.54 KB)
ðŸ“„ abbrev.rb(3.47 KB)
ðŸ“„ base64.rb(13.22 KB)
ðŸ“„ benchmark.rb(18.42 KB)
ðŸ“ bigdecimal
ðŸ“„ bigdecimal.rb(130 B)
ðŸ“„ bundled_gems.rb(6.86 KB)
ðŸ“ cgi
ðŸ“„ cgi.rb(9.83 KB)
ðŸ“„ coverage.rb(368 B)
ðŸ“ csv
ðŸ“„ csv.rb(92.46 KB)
ðŸ“„ date.rb(1.17 KB)
ðŸ“„ delegate.rb(11.68 KB)
ðŸ“ did_you_mean
ðŸ“„ did_you_mean.rb(5.36 KB)
ðŸ“ digest
ðŸ“„ digest.rb(3.3 KB)
ðŸ“ drb
ðŸ“„ drb.rb(50 B)
ðŸ“ erb
ðŸ“„ erb.rb(14.53 KB)
ðŸ“ error_highlight
ðŸ“„ error_highlight.rb(84 B)
ðŸ“„ expect.rb(2.19 KB)
ðŸ“ fiddle
ðŸ“„ fiddle.rb(2.88 KB)
ðŸ“„ fileutils.rb(78.69 KB)
ðŸ“„ find.rb(2.52 KB)
ðŸ“ forwardable
ðŸ“„ forwardable.rb(9.03 KB)
ðŸ“„ getoptlong.rb(20.26 KB)
ðŸ“ io
ðŸ“„ ipaddr.rb(20.93 KB)
ðŸ“ json
ðŸ“„ json.rb(19.62 KB)
ðŸ“„ kconv.rb(5.72 KB)
ðŸ“ logger
ðŸ“„ logger.rb(22.03 KB)
ðŸ“„ mkmf.rb(88.69 KB)
ðŸ“„ monitor.rb(6.75 KB)
ðŸ“„ mutex_m.rb(2.36 KB)
ðŸ“ net
ðŸ“ objspace
ðŸ“„ objspace.rb(4.14 KB)
ðŸ“„ observer.rb(6.38 KB)
ðŸ“„ open-uri.rb(25.84 KB)
ðŸ“ open3
ðŸ“„ open3.rb(47.51 KB)
ðŸ“ openssl
ðŸ“„ openssl.rb(1.03 KB)
ðŸ“„ optionparser.rb(59 B)
ðŸ“ optparse
ðŸ“„ optparse.rb(61.82 KB)
ðŸ“„ ostruct.rb(14.22 KB)
ðŸ“„ pathname.rb(16.85 KB)
ðŸ“„ pp.rb(17.24 KB)
ðŸ“„ prettyprint.rb(15.93 KB)
ðŸ“ prism
ðŸ“„ prism.rb(3.17 KB)
ðŸ“„ pstore.rb(20.36 KB)
ðŸ“ psych
ðŸ“„ psych.rb(24.44 KB)
ðŸ“ random
ðŸ“„ readline.rb(215 B)
ðŸ“ reline
ðŸ“„ reline.rb(14.7 KB)
ðŸ“„ resolv-replace.rb(1.76 KB)
ðŸ“„ resolv.rb(85.03 KB)
ðŸ“ rinda
ðŸ“ ripper
ðŸ“„ ripper.rb(2.44 KB)
ðŸ“ ruby_vm
ðŸ“„ securerandom.rb(2.06 KB)
ðŸ“ set
ðŸ“„ set.rb(24.94 KB)
ðŸ“„ shellwords.rb(7.11 KB)
ðŸ“„ singleton.rb(3.94 KB)
ðŸ“„ socket.rb(44.04 KB)
ðŸ“ syntax_suggest
ðŸ“„ syntax_suggest.rb(74 B)
ðŸ“ syslog
ðŸ“„ tempfile.rb(14.73 KB)
ðŸ“„ time.rb(23.74 KB)
ðŸ“„ timeout.rb(5.69 KB)
ðŸ“„ tmpdir.rb(4.93 KB)
ðŸ“„ tsort.rb(14.29 KB)
ðŸ“„ un.rb(11.17 KB)
ðŸ“ unicode_normalize
ðŸ“ uri
ðŸ“„ uri.rb(3.06 KB)
ðŸ“ vendor_ruby
ðŸ“„ weakref.rb(1.36 KB)
ðŸ“ yaml
ðŸ“„ yaml.rb(2.13 KB)

Editing: timeout.rb

# frozen_string_literal: true
# Timeout long-running blocks
#
# == Synopsis
#
#   require 'timeout'
#   status = Timeout::timeout(5) {
#     # Something that should be interrupted if it takes more than 5 seconds...
#   }
#
# == Description
#
# Timeout provides a way to auto-terminate a potentially long-running
# operation if it hasn't finished in a fixed amount of time.
#
# Previous versions didn't use a module for namespacing, however
# #timeout is provided for backwards compatibility.  You
# should prefer Timeout.timeout instead.
#
# == Copyright
#
# Copyright:: (C) 2000  Network Applied Communication Laboratory, Inc.
# Copyright:: (C) 2000  Information-technology Promotion Agency, Japan

module Timeout
  VERSION = "0.4.1"

# Internal error raised to when a timeout is triggered.
  class ExitException < Exception
    def exception(*)
      self
    end
  end

# Raised by Timeout.timeout when the block times out.
  class Error < RuntimeError
    def self.handle_timeout(message)
      exc = ExitException.new(message)

begin
        yield exc
      rescue ExitException => e
        raise new(message) if exc.equal?(e)
        raise
      end
    end
  end

# :stopdoc:
  CONDVAR = ConditionVariable.new
  QUEUE = Queue.new
  QUEUE_MUTEX = Mutex.new
  TIMEOUT_THREAD_MUTEX = Mutex.new
  @timeout_thread = nil
  private_constant :CONDVAR, :QUEUE, :QUEUE_MUTEX, :TIMEOUT_THREAD_MUTEX

class Request
    attr_reader :deadline

def initialize(thread, timeout, exception_class, message)
      @thread = thread
      @deadline = GET_TIME.call(Process::CLOCK_MONOTONIC) + timeout
      @exception_class = exception_class
      @message = message

@mutex = Mutex.new
      @done = false # protected by @mutex
    end

def done?
      @mutex.synchronize do
        @done
      end
    end

def expired?(now)
      now >= @deadline
    end

def interrupt
      @mutex.synchronize do
        unless @done
          @thread.raise @exception_class, @message
          @done = true
        end
      end
    end

def finished
      @mutex.synchronize do
        @done = true
      end
    end
  end
  private_constant :Request

def self.create_timeout_thread
    watcher = Thread.new do
      requests = []
      while true
        until QUEUE.empty? and !requests.empty? # wait to have at least one request
          req = QUEUE.pop
          requests << req unless req.done?
        end
        closest_deadline = requests.min_by(&:deadline).deadline

now = 0.0
        QUEUE_MUTEX.synchronize do
          while (now = GET_TIME.call(Process::CLOCK_MONOTONIC)) < closest_deadline and QUEUE.empty?
            CONDVAR.wait(QUEUE_MUTEX, closest_deadline - now)
          end
        end

requests.each do |req|
          req.interrupt if req.expired?(now)
        end
        requests.reject!(&:done?)
      end
    end
    ThreadGroup::Default.add(watcher) unless watcher.group.enclosed?
    watcher.name = "Timeout stdlib thread"
    watcher.thread_variable_set(:"\0__detached_thread__", true)
    watcher
  end
  private_class_method :create_timeout_thread

def self.ensure_timeout_thread_created
    unless @timeout_thread and @timeout_thread.alive?
      TIMEOUT_THREAD_MUTEX.synchronize do
        unless @timeout_thread and @timeout_thread.alive?
          @timeout_thread = create_timeout_thread
        end
      end
    end
  end

# We keep a private reference so that time mocking libraries won't break
  # Timeout.
  GET_TIME = Process.method(:clock_gettime)
  private_constant :GET_TIME

# :startdoc:

# Perform an operation in a block, raising an error if it takes longer than
  # +sec+ seconds to complete.
  #
  # +sec+:: Number of seconds to wait for the block to terminate. Any number
  #         may be used, including Floats to specify fractional seconds. A
  #         value of 0 or +nil+ will execute the block without any timeout.
  # +klass+:: Exception Class to raise if the block fails to terminate
  #           in +sec+ seconds.  Omitting will use the default, Timeout::Error
  # +message+:: Error message to raise with Exception Class.
  #             Omitting will use the default, "execution expired"
  #
  # Returns the result of the block *if* the block completed before
  # +sec+ seconds, otherwise throws an exception, based on the value of +klass+.
  #
  # The exception thrown to terminate the given block cannot be rescued inside
  # the block unless +klass+ is given explicitly. However, the block can use
  # ensure to prevent the handling of the exception.  For that reason, this
  # method cannot be relied on to enforce timeouts for untrusted blocks.
  #
  # If a scheduler is defined, it will be used to handle the timeout by invoking
  # Scheduler#timeout_after.
  #
  # Note that this is both a method of module Timeout, so you can <tt>include
  # Timeout</tt> into your classes so they have a #timeout method, as well as
  # a module method, so you can call it directly as Timeout.timeout().
  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
  module_function :timeout
end

X7ROOT File Manager

Editing: timeout.rb

Upload File

Create Folder