Sha256: fd64428c744116890d6c0433fd4426c6ff3e68224dfcbd94164ee45c7d742057
Contents?: true
Size: 1.49 KB
Versions: 11
Compression:
Stored size: 1.49 KB
Contents
# = Pool
#
# Generalized object pool implementation. Implemented as a thread
# safe stack. Exclusive locking is needed both for push and pop.
#
# == Author
#
# * George Moschovitis
#
# == Todo
#
# * Could use the SizedQueue/Queue?
#
# == Copying
#
# Copyright (c) 2004 George Moschovitis
#
# Ruby License
#
# This module is free software. You may use, modify, and/or redistribute this
# software under the same terms as Ruby.
#
# This program is distributed in the hope that it will be useful, but WITHOUT
# ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS
# FOR A PARTICULAR PURPOSE.
require 'thread'
require 'monitor'
# = Pool
#
# Generalized object pool implementation. Implemented as a thread
# safe stack. Exclusive locking is needed both for push and pop.
#
class Pool < Array
include MonitorMixin
def initialize
super
@cv = new_cond()
end
# Add, restore an object to the pool.
def push(obj)
synchronize do
super
@cv.signal()
end
end
# Obtain an object from the pool.
def pop
synchronize do
@cv.wait_while { empty? }
super
end
end
# Obtains an object, passes it to a block for processing
# and restores it to the pool.
def obtain
result = nil
begin
obj = pop()
result = yield(obj)
ensure
push(obj)
end
return result
end
end
# _____ _
# |_ _|__ ___| |_
# | |/ _ \/ __| __|
# | | __/\__ \ |_
# |_|\___||___/\__|
#
# TODO
=begin #testing
=end
Version data entries
11 entries across 11 versions & 2 rubygems