Class: Extlib::Pooling::Pool
Instance Attribute Summary collapse
-
#available ⇒ Object
readonly
Returns the value of attribute available.
-
#used ⇒ Object
readonly
Returns the value of attribute used.
Instance Method Summary collapse
- #delete(instance) ⇒ Object
- #dispose ⇒ Object
- #expired? ⇒ Boolean
- #flush! ⇒ Object
-
#initialize(max_size, resource, args) ⇒ Pool
constructor
A new instance of Pool.
- #inspect ⇒ Object
- #lock ⇒ Object
- #new ⇒ Object
- #release(instance) ⇒ Object
- #scavenge_interval ⇒ Object
- #size ⇒ Object (also: #length)
- #wait ⇒ Object
Constructor Details
#initialize(max_size, resource, args) ⇒ Pool
Returns a new instance of Pool.
129 130 131 132 133 134 135 136 137 138 139 140 |
# File 'lib/extlib/pooling.rb', line 129 def initialize(max_size, resource, args) raise ArgumentError.new("+max_size+ should be a Fixnum but was #{max_size.inspect}") unless Fixnum === max_size raise ArgumentError.new("+resource+ should be a Class but was #{resource.inspect}") unless Class === resource @max_size = max_size @resource = resource @args = args @available = [] @used = {} Extlib::Pooling.append_pool(self) end |
Instance Attribute Details
#available ⇒ Object (readonly)
Returns the value of attribute available.
126 127 128 |
# File 'lib/extlib/pooling.rb', line 126 def available @available end |
#used ⇒ Object (readonly)
Returns the value of attribute used.
127 128 129 |
# File 'lib/extlib/pooling.rb', line 127 def used @used end |
Instance Method Details
#delete(instance) ⇒ Object
191 192 193 194 195 196 197 198 |
# File 'lib/extlib/pooling.rb', line 191 def delete(instance) lock.synchronize do instance.instance_variable_set(:@__pool, nil) @used.delete(instance.object_id) wait.signal end nil end |
#dispose ⇒ Object
213 214 215 216 217 |
# File 'lib/extlib/pooling.rb', line 213 def dispose flush! @resource.__pools.delete(@args) !Extlib::Pooling.pools.delete?(self).nil? end |
#expired? ⇒ Boolean
219 220 221 222 223 224 225 226 227 |
# File 'lib/extlib/pooling.rb', line 219 def expired? @available.each do |instance| if Extlib.exiting || instance.instance_variable_get(:@__allocated_in_pool) + Extlib::Pooling.scavenger_interval <= (Time.now + 0.02) instance.dispose @available.delete(instance) end end size == 0 end |
#flush! ⇒ Object
209 210 211 |
# File 'lib/extlib/pooling.rb', line 209 def flush! @available.pop.dispose until @available.empty? end |
#inspect ⇒ Object
205 206 207 |
# File 'lib/extlib/pooling.rb', line 205 def inspect "#<Extlib::Pooling::Pool<#{@resource.name}> available=#{@available.size} used=#{@used.size} size=#{@max_size}>" end |
#lock ⇒ Object
142 143 144 |
# File 'lib/extlib/pooling.rb', line 142 def lock @resource.__pool_lock end |
#new ⇒ Object
154 155 156 157 158 159 160 161 162 163 164 165 166 167 168 169 170 171 172 173 174 175 176 177 178 179 |
# File 'lib/extlib/pooling.rb', line 154 def new instance = nil begin lock.synchronize do if @available.size > 0 instance = @available.pop @used[instance.object_id] = instance elsif @used.size < @max_size instance = @resource.__new(*@args) raise InvalidResourceError.new("#{@resource} constructor created a nil object") if instance.nil? raise InvalidResourceError.new("#{instance} is already part of the pool") if @used.include? instance instance.instance_variable_set(:@__pool, self) instance.instance_variable_set(:@__allocated_in_pool, Time.now) @used[instance.object_id] = instance else # Wait for another thread to release an instance. # If we exhaust the pool and don't release the active instance, # we'll wait here forever, so it's *very* important to always # release your services and *never* exhaust the pool within # a single thread. wait.wait(lock) end end end until instance instance end |
#release(instance) ⇒ Object
181 182 183 184 185 186 187 188 189 |
# File 'lib/extlib/pooling.rb', line 181 def release(instance) lock.synchronize do instance.instance_variable_set(:@__allocated_in_pool, Time.now) @used.delete(instance.object_id) @available.push(instance) wait.signal end nil end |
#scavenge_interval ⇒ Object
150 151 152 |
# File 'lib/extlib/pooling.rb', line 150 def scavenge_interval @resource.scavenge_interval end |
#size ⇒ Object Also known as: length
200 201 202 |
# File 'lib/extlib/pooling.rb', line 200 def size @used.size + @available.size end |
#wait ⇒ Object
146 147 148 |
# File 'lib/extlib/pooling.rb', line 146 def wait @resource.__pool_wait end |