class MessagePack::Factory::Pool::AbstractPool
Public Class Methods
new(size, &block)
click to toggle source
# File lib/msgpack/factory.rb, line 92 def initialize(size, &block) @size = size @new_member = block @members = [] end
Public Instance Methods
checkin(member)
click to toggle source
# File lib/msgpack/factory.rb, line 102 def checkin(member) # If the pool is already full, we simply drop the extra member. # This is because contrary to a connection pool, creating an extra instance # is extremely unlikely to cause some kind of resource exhaustion. # # We could cycle the members (keep the newer one) but first It's more work and second # the older member might have been created pre-fork, so it might be at least partially # in shared memory. if member && @members.size < @size member.reset @members << member end end
checkout()
click to toggle source
# File lib/msgpack/factory.rb, line 98 def checkout @members.pop || @new_member.call end