Sha256: a4e38c735c993bce514f432dedbdcec4f73092ec0a304a78717112e0f31ebe94
Contents?: true
Size: 929 Bytes
Versions: 130
Compression:
Stored size: 929 Bytes
Contents
require "ev/ruby"
require "thread"
class FakeThread
def initialize(*args)
yield(*args)
end
def join
end
end
class ThreadLimiter
def initialize(limit)
@limit = limit
@count = 0
@threads = []
@mutex = Mutex.new
@cv = ConditionVariable.new
every(1) do
@mutex.synchronize do
@threads.dup.each do |t|
unless t.alive?
$stderr.puts "Found dead thread."
@threads.delete(t)
@count -= 1
@cv.signal
end
end
end
end
end
def wait
if block_given?
self.wait
yield
self.signal
else
@mutex.synchronize do
@threads << Thread.current
@count += 1
@cv.wait(@mutex) if @count > @limit
end
end
end
def signal
@mutex.synchronize do
@threads.delete(Thread.current)
@count -= 1
@cv.signal
end
end
end
Version data entries
130 entries across 130 versions & 11 rubygems