提交 c4ac300d 编写于 作者: A Aaron Patterson 提交者: eileencodes

Merge pull request #36296 from jhawthorn/dont_fear_the_reaper

Use a single thread for all ConnectionPool Reapers
上级 5ac76f4f
......@@ -294,15 +294,33 @@ def initialize(pool, frequency)
@frequency = frequency
end
@@mutex = Mutex.new
@@pools = {}
def self.register_pool(pool, frequency) # :nodoc:
@@mutex.synchronize do
if @@pools.key?(frequency)
@@pools[frequency] << pool
else
@@pools[frequency] = [pool]
Thread.new(frequency) do |t|
loop do
sleep t
@@mutex.synchronize do
@@pools[frequency].each do |p|
p.reap
p.flush
end
end
end
end
end
end
end
def run
return unless frequency && frequency > 0
Thread.new(frequency, pool) { |t, p|
loop do
sleep t
p.reap
p.flush
end
}
self.class.register_pool(pool, frequency)
end
end
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册