Method: Async::Scheduler#close

Defined in:
lib/async/scheduler.rb

#close ⇒ Object

Terminate all child tasks and close the scheduler.

[View source]

124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
 
# File 'lib/async/scheduler.rb', line 124

def close
	self.run_loop do
		until self.terminate
			self.run_once!
		end
	end
	
	Kernel.raise "Closing scheduler with blocked operations!" if @blocked > 0
ensure
	# We want `@selector = nil` to be a visible side effect from this point forward, specifically in `#interrupt` and `#unblock`. If the selector is closed, then we don't want to push any fibers to it.
	selector = @selector
	@selector = nil
	
	selector&.close
	
	worker_pool = @worker_pool
	@worker_pool = nil
	
	worker_pool&.close
	
	consume
end