Sha256: ce2e36115913f217f2b975bf68d43c8ded762a7ee55d8ae59e099dfcf9234884
Contents?: true
Size: 1.01 KB
Versions: 36
Compression:
Stored size: 1.01 KB
Contents
require 'thread'
module Tins
class Limited
# Create a Limited instance, that runs _maximum_ threads at most.
def initialize(maximum)
@mutex = Mutex.new
@continue = ConditionVariable.new
@maximum = Integer(maximum)
raise ArgumentError, "maximum < 1" if @maximum < 1
@count = 0
@tg = ThreadGroup.new
end
# The maximum number of worker threads.
attr_reader :maximum
# Execute _maximum_ number of threads in parallel.
def execute
@mutex.synchronize do
loop do
if @count < @maximum
@count += 1
Thread.new do
@tg.add Thread.current
yield
@mutex.synchronize { @count -= 1 }
@continue.signal
end
return
else
@continue.wait(@mutex)
end
end
end
end
def wait
@tg.list.each(&:join)
end
def process
yield self
ensure
wait
end
end
end
require 'tins/alias'
Version data entries
36 entries across 27 versions & 2 rubygems