Class: Async::IO::Notification

Inherits:
Object
  • Object
show all
Defined in:
lib/async/io/notification.rb

Overview

A cross-reactor/process notification pipe.

Instance Method Summary collapse

Constructor Details

#initialize ⇒ Notification

Returns a new instance of Notification.



12
13
14
15
16
17
18
 
# File 'lib/async/io/notification.rb', line 12

def initialize
	pipe = ::IO.pipe
	
	# We could call wait and signal from different reactors/threads/processes, so we don't create wrappers here, because they are not thread safe by design.
	@input = pipe.first
	@output = pipe.last
end

Instance Method Details

#close ⇒ Object 



20
21
22
23
 
# File 'lib/async/io/notification.rb', line 20

def close
	@input.close
	@output.close
end

#signal ⇒ void

This method returns an undefined value.

Signal to a given task that it should resume operations.



37
38
39
40
41
42
 
# File 'lib/async/io/notification.rb', line 37

def signal
	wrapper = Async::IO::Generic.new(@output)
	wrapper.write(".")
ensure
	wrapper.reactor = nil
end

#wait ⇒ Object

Wait for signal to be called.

Returns:

  • (Object) 


27
28
29
30
31
32
33
 
# File 'lib/async/io/notification.rb', line 27

def wait
	wrapper = Async::IO::Generic.new(@input)
	wrapper.read(1)
ensure
	# Remove the wrapper from the reactor.
	wrapper.reactor = nil
end