Class: Async::Notification

Inherits:
Condition show all
Defined in:
lib/async/notification.rb

Overview

A synchronization primitive, which allows fibers to wait until a notification is received. Does not block the task which signals the notification. Waiting tasks are resumed on next iteration of the reactor.

Direct Known Subclasses

Queue

Defined Under Namespace

Classes: Signal

Instance Method Summary collapse

Methods inherited from Condition

#empty?, #initialize, #wait

Constructor Details

This class inherits a constructor from Async::Condition

Instance Method Details

#signal(value = nil, task: Task.current) ⇒ void

This method returns an undefined value.

Signal to a given task that it should resume operations.



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

def signal(value = nil, task: Task.current)
	return if @waiting.empty?
	
	task.reactor << Signal.new(@waiting, value)
	
	@waiting = []
	
	return nil
end