Class: MessagePack::Factory::Pool::MemberPool
- Inherits:
-
Object
- Object
- MessagePack::Factory::Pool::MemberPool
- Defined in:
- lib/msgpack/factory.rb,
lib/msgpack/factory.rb
Instance Method Summary collapse
-
#initialize(size, &block) ⇒ MemberPool
constructor
A new instance of MemberPool.
- #with ⇒ Object
Constructor Details
#initialize(size, &block) ⇒ MemberPool
Returns a new instance of MemberPool.
92 93 94 95 96 |
# File 'lib/msgpack/factory.rb', line 92 def initialize(size, &block) @size = size @new_member = block @members = [] end |
Instance Method Details
#with ⇒ Object
98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 |
# File 'lib/msgpack/factory.rb', line 98 def with member = @members.pop || @new_member.call begin yield member ensure # 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 end |