class Async::Container::Threaded

def stop
	@reactors.each(&:stop)
	@threads.each(&:join)
end