Sha256: 15cbe8d8ee8254178fe65743d0a0fa318a5cb2a2136e09c8f8521cf5c92adf61
Contents?: true
Size: 854 Bytes
Versions: 135
Compression:
Stored size: 854 Bytes
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
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
yield
@mutex.synchronize { @count -= 1 }
@continue.signal
end
return
else
@continue.wait(@mutex)
end
end
end
end
end
end
require 'tins/alias'
Version data entries
135 entries across 128 versions & 9 rubygems