Provides pooling support to class it got included in.
Pooling of objects is a faster way of aquiring instances of objects compared to regular allocation and initialization because instances are keeped in memory reused.
Classes that include Pooling module have re-defined new method that returns instances acquired from pool.
Term resource is used for any type of poolable objects and should NOT be thought as DataMapper Resource or ActiveResource resource and such.
In Data Objects connections are pooled so that it is unnecessary to allocate and initialize connection object each time connection is needed, like per request in a web application.
Pool obviously has to be thread safe because state of object is reset when it is released.
# File lib/extlib/pooling.rb, line 95 def self.__pool_lock @__pool_lock end
# File lib/extlib/pooling.rb, line 99 def self.__pool_wait @__pool_wait end
# File lib/extlib/pooling.rb, line 107 def self.__pools @__pools end
# File lib/extlib/pooling.rb, line 71 def self.append_pool(pool) lock.synchronize do pools << pool end Extlib::Pooling.scavenger end
# File lib/extlib/pooling.rb, line 85 def self.included(target) target.class_eval do class << self alias __new new end @__pools = {} @__pool_lock = Mutex.new @__pool_wait = ConditionVariable.new def self.__pool_lock @__pool_lock end def self.__pool_wait @__pool_wait end def self.new(*args) (@__pools[args] ||= __pool_lock.synchronize { Pool.new(self.pool_size, self, args) }).new end def self.__pools @__pools end def self.pool_size 8 end end end
# File lib/extlib/pooling.rb, line 78 def self.lock @lock ||= Mutex.new end
# File lib/extlib/pooling.rb, line 103 def self.new(*args) (@__pools[args] ||= __pool_lock.synchronize { Pool.new(self.pool_size, self, args) }).new end
# File lib/extlib/pooling.rb, line 67 def self.pools @pools ||= Set.new end
# File lib/extlib/pooling.rb, line 32 def self.scavenger unless scavenger? @scavenger = Thread.new do running = true while running do # Sleep before we actually start doing anything. # Otherwise we might clean up something we just made sleep(scavenger_interval) lock.synchronize do pools.each do |pool| # This is a useful check, but non-essential, and right now it breaks lots of stuff. # if pool.expired? pool.lock.synchronize do if pool.expired? pool.dispose end end # end end # The pool is empty, we stop the scavenger # It wil be restarted if new resources are added again if pools.empty? running = false end end end # loop end end @scavenger.priority = -10 @scavenger end
Generated with the Darkfish Rdoc Generator 2.