Class: Threadz::Sleeper

Inherits:
Object
  • Object
show all
Defined in:
lib/threadz/sleeper.rb

Instance Method Summary collapse

Constructor Details

#initialize ⇒ Sleeper

Returns a new instance of Sleeper.



6
7
8
 
# File 'lib/threadz/sleeper.rb', line 6

def initialize
	@waiters = Queue.new
end

Instance Method Details

#broadcast ⇒ Object 



40
41
42
43
44
45
46
47
 
# File 'lib/threadz/sleeper.rb', line 40

def broadcast
	while !@waiters.empty?
		begin
			@waiters.pop(true).wakeup
		rescue ThreadError => e
		end
	end
end

#signal ⇒ Object 



30
31
32
33
34
35
36
37
38
 
# File 'lib/threadz/sleeper.rb', line 30

def signal
	begin
		begin
			waiter = @waiters.pop(true)
		rescue ThreadError => e
		end
	end while waiter[:'__THREADZ_IS_SLEEPING']
	waiter.wakeup if waiter
end

#wait(timeout = 0) ⇒ Object 



10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
 
# File 'lib/threadz/sleeper.rb', line 10

def wait(timeout=0)
	if(timeout == nil || timeout <= 0)
		@waiters << Thread.current
		Thread.stop
		return true
	else
		begin
			@waiters << Thread.current
			status = Timeout::timeout(timeout) {
			  Thread.current[:'__THREADZ_IS_SLEEPING'] = true
			  Thread.stop
			  Thread.current[:'__THREADZ_IS_SLEEPING'] = false
			}
			return true
		rescue Timeout::Error
			return false
		end
	end
end