class Bundler::ConnectionPool

Parent:: Объект

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

Пример использования с блоком (быстрее):

@pool = Bundler::ConnectionPool.new { Redis.new }

@pool.with do |redis|
  redis.lpop('my-list') if redis.llen('my-list') > 0
end

Использование необязательного переопределения таймаута (для этого отдельного вызова)

@pool.with(timeout: 2.0) do |redis|
  redis.lpop('my-list') if redis.llen('my-list') > 0
end

Пример использования, заменяющего существующее соединение (медленнее):

$redis = Bundler::ConnectionPool.wrap { Redis.new }

def do_work
  $redis.lpop('my-list') if $redis.llen('my-list') > 0
end

Принимает следующие параметры:

:size - количество соединений в пуле, по умолчанию 5
:timeout - количество времени ожидания соединения, если оно не доступно в настоящее время, по умолчанию 5 секунд

Константы

DEFAULTS

GLOBAL_MONOTONIC_CLOCK

Часы, которые нельзя установить и представляют собой монотонное время с момента некоторой неопределенной начальной точки.

@!visibility private

VERSION

Публичные методы класса

monotonic_time() Показать исходный код

# File lib/bundler/vendor/connection_pool/lib/connection_pool/monotonic_time.rb, line 62
def monotonic_time
  GLOBAL_MONOTONIC_CLOCK.get_time
end

Возвращает текущее время, отслеживаемое монотонными часами приложения.

@return [Float] Текущее монотонное время, если `since` не задано, иначе

the elapsed monotonic time between `since` and the current time

new(options = {}, &block) Показать исходный код

# File lib/bundler/vendor/connection_pool/lib/connection_pool.rb, line 44
def initialize(options = {}, &block)
  raise ArgumentError, 'Connection pool requires a block' unless block

  options = DEFAULTS.merge(options)

  @size = options.fetch(:size)
  @timeout = options.fetch(:timeout)

  @available = TimedStack.new(@size, &block)
  @key = :"current-#{@available.object_id}"
  @key_count = :"current-#{@available.object_id}-count"
end

wrap(options, &block) Показать исходный код

# File lib/bundler/vendor/connection_pool/lib/connection_pool.rb, line 40
def self.wrap(options, &block)
  Wrapper.new(options, &block)
end

Публичные методы экземпляров

available() Показать исходный код

# File lib/bundler/vendor/connection_pool/lib/connection_pool.rb, line 122
def available
  @available.length
end

Количество элементов пула, доступных для получения в данный момент.

checkin() Показать исходный код

# File lib/bundler/vendor/connection_pool/lib/connection_pool.rb, line 97
def checkin
  if ::Thread.current[@key]
    if ::Thread.current[@key_count] == 1
      @available.push(::Thread.current[@key])
      ::Thread.current[@key]= nil
    else
      ::Thread.current[@key_count]-= 1
    end
  else
    raise Bundler::ConnectionPool::Error, 'no connections are checked out'
  end

  nil
end

checkout(options = {}) Показать исходный код

# File lib/bundler/vendor/connection_pool/lib/connection_pool.rb, line 87
def checkout(options = {})
  if ::Thread.current[@key]
    ::Thread.current[@key_count]+= 1
    ::Thread.current[@key]
  else
    ::Thread.current[@key_count]= 1
    ::Thread.current[@key]= @available.pop(options[:timeout] || @timeout)
  end
end

get_time() Показать исходный код

# File lib/bundler/vendor/connection_pool/lib/connection_pool/monotonic_time.rb, line 15
def get_time
  Process.clock_gettime(Process::CLOCK_MONOTONIC)
end

@!visibility private

shutdown(&block) Показать исходный код

# File lib/bundler/vendor/connection_pool/lib/connection_pool.rb, line 112
def shutdown(&block)
  @available.shutdown(&block)
end

size() Показать исходный код

# File lib/bundler/vendor/connection_pool/lib/connection_pool.rb, line 117
def size
  @size
end

Размер данного пула соединений

with(options = {}) { |conn| ... } Показать исходный код

# File lib/bundler/vendor/connection_pool/lib/connection_pool.rb, line 60
def with(options = {})
  Thread.handle_interrupt(Exception => :never) do
    conn = checkout(options)
    begin
      Thread.handle_interrupt(Exception => :immediate) do
        yield conn
      end
    ensure
      checkin
    end
  end
end

MRI

Ruby Core © 1993–2017 Yukihiro Matsumoto
Licensed under the Ruby License.
Ruby Standard Library © contributors
Licensed under their own licenses.