Method: OnceQueue#initialize

Defined in:
lib/netutils/oncequeue.rb

#initialize ⇒ OnceQueue

Returns a new instance of OnceQueue.



2
3
4
5
6
7
8
9
10
11
 
# File 'lib/netutils/oncequeue.rb', line 2

def initialize
	@element = []
	@queue = []
	@mutex = Thread::Mutex.new
	@cond = Thread::ConditionVariable.new
	@empty = Thread::ConditionVariable.new
	@processing = 0
	@total = 0
	@errors = 0
end