class Mongoid::Sessions::SessionPool::Reaper

Attributes

frequency[R]
pool[R]
reaper[R]

Public Class Methods

new(frequency, pool) click to toggle source
# File lib/mongoid_connection_pool/mongoid/sessions/session_pool.rb, line 238
def initialize(frequency, pool)
  @frequency = frequency
  @pool = pool
end

Public Instance Methods

alive?() click to toggle source
# File lib/mongoid_connection_pool/mongoid/sessions/session_pool.rb, line 243
def alive?
  return true unless frequency
  # under rbx 2.2.4 this now works, also works correctly under mri at latest patch levels
  reaper.alive?
end
run() click to toggle source
# File lib/mongoid_connection_pool/mongoid/sessions/session_pool.rb, line 249
def run
  return unless frequency
  @reaper = Thread.new(frequency, pool) do |t, p|
    while true
      sleep t
      p.reap
    end
  end
end