class ActiveRecord::ConnectionAdapters::ConnectionPool::Queue

Parent:: Object

Очередь пула соединений Active Record

Потокобезопасная, справедливая очередь LIFO. Предназначена для использования с ConnectionPool, с которым она разделяет монитор.

Открытые методы класса

new(lock = Monitor.new) Показать исходный код

# File activerecord/lib/active_record/connection_adapters/abstract/connection_pool/queue.rb, line 14
def initialize(lock = Monitor.new)
  @lock = lock
  @cond = @lock.new_cond
  @num_waiting = 0
  @queue = []
end

Открытые методы экземпляра

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

# File activerecord/lib/active_record/connection_adapters/abstract/connection_pool/queue.rb, line 37
def add(element)
  synchronize do
    @queue.push element
    @cond.signal
  end
end

Добавить element в очередь. Никогда не блокирует.

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

# File activerecord/lib/active_record/connection_adapters/abstract/connection_pool/queue.rb, line 22
def any_waiting?
  synchronize do
    @num_waiting > 0
  end
end

Проверить, ожидают ли в данный момент какие-либо потоки в очереди.

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

# File activerecord/lib/active_record/connection_adapters/abstract/connection_pool/queue.rb, line 52
def clear
  synchronize do
    @queue.clear
  end
end

Удалить все элементы из очереди.

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

# File activerecord/lib/active_record/connection_adapters/abstract/connection_pool/queue.rb, line 45
def delete(element)
  synchronize do
    @queue.delete(element)
  end
end

Если element находится в очереди, удалить и вернуть его, или nil.

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

# File activerecord/lib/active_record/connection_adapters/abstract/connection_pool/queue.rb, line 30
def num_waiting
  synchronize do
    @num_waiting
  end
end

Возвращает количество потоков, которые в данный момент ожидают в этой очереди.

poll(timeout = nil) Показать исходный код

# File activerecord/lib/active_record/connection_adapters/abstract/connection_pool/queue.rb, line 72
def poll(timeout = nil)
  synchronize { internal_poll(timeout) }
end

Удалить первый элемент из очереди.

Если timeout не задано, удалить и вернуть первый элемент из очереди, если число доступных элементов строго больше, чем число потоков, ожидающих (то есть, не занимать очередь). В противном случае вернуть nil.

Если timeout задано, заблокировать, если нет доступного элемента, ожидая до timeout секунд, пока элемент не станет доступным.

Возбуждает:

ActiveRecord::ConnectionTimeoutError, если timeout задано и ни один элемент

не становится доступным в течение timeout секунд,