method
spawn_thread
v8.1.1 -
Show latest stable
- Class:
ActiveRecord::ConnectionAdapters::ConnectionPool::Reaper
spawn_thread(frequency)private
No documentation available.
# File activerecord/lib/active_record/connection_adapters/abstract/connection_pool/reaper.rb, line 66
def spawn_thread(frequency)
Thread.new(frequency) do |t|
# Advise multi-threaded app servers to ignore this thread for
# the purposes of fork safety warnings
Thread.current.thread_variable_set(:fork_safe, true)
Thread.current.name = "AR Pool Reaper"
running = true
while running
sleep t
refs = nil
@mutex.synchronize do
refs = @pools[frequency]
refs.select! do |pool|
pool.weakref_alive? && !pool.discarded?
rescue WeakRef::RefError
end
if refs.empty?
@pools.delete(frequency)
@threads.delete(frequency)
running = false
end
end
if running
pools(refs).each do |pool|
pool.reaper_lock do
pool.reap
pool.flush
pool.prepopulate
pool.retire_old_connections
pool.keep_alive
pool.preconnect
end
end
end
end
end
end