Class: OnceQueue

Inherits:
Object
  • Object
show all
Defined in:
lib/netutils/oncequeue.rb

Instance Method Summary collapse

Constructor Details

#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

Instance Method Details

#count ⇒ Object 



18
19
20
21
22
 
# File 'lib/netutils/oncequeue.rb', line 18

def count
	@mutex.synchronize do
		__count
	end
end

#dequeue ⇒ Object 



45
46
47
48
49
50
51
 
# File 'lib/netutils/oncequeue.rb', line 45

def dequeue
	@mutex.synchronize do
		@cond.wait(@mutex) while @queue.empty?
		@processing += 1
			@queue.shift
	end
end

#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

#enqueue(v) ⇒ Object 



36
37
38
39
40
41
42
43
 
# File 'lib/netutils/oncequeue.rb', line 36

def enqueue(v)
	@mutex.synchronize do
		break if @element.include?(v)
		@element.push(v)
		@queue.push(v)
		@cond.signal
	end
end

#error ⇒ Object 



61
62
63
64
65
 
# File 'lib/netutils/oncequeue.rb', line 61

def error
	@mutex.synchronize do
		@errors += 1
	end
end

#errors ⇒ Object 



30
31
32
33
34
 
# File 'lib/netutils/oncequeue.rb', line 30

def errors
	@mutex.synchronize do
		@errors
	end
end

#synchronize ⇒ Object 



67
68
69
70
71
 
# File 'lib/netutils/oncequeue.rb', line 67

def synchronize
	@mutex.synchronize do
		yield
	end
end

#total ⇒ Object 



24
25
26
27
28
 
# File 'lib/netutils/oncequeue.rb', line 24

def total
	@mutex.synchronize do
		@total
	end
end

#wait_all ⇒ Object 



73
74
75
76
77
 
# File 'lib/netutils/oncequeue.rb', line 73

def wait_all
	@mutex.synchronize do
		@empty.wait(@mutex) if __count > 0
	end
end