Method: OnceQueue#done

Defined in:
lib/netutils/oncequeue.rb

#done(v) ⇒ Object



53
54
55
56
57
58
59
# File 'lib/netutils/oncequeue.rb', line 53

def done(v)
	@mutex.synchronize do
		@processing -= 1
		@empty.signal if __count === 0
		@total += 1
	end
end