---

thwait.rb

# frozen_string_literal: false # # thwait.rb - thread synchronization class # $Release Version: 0.9 $ # $Revision: 1.3 $ # by Keiju ISHITSUKA(Nihon Rational Software Co.,Ltd.) require "thread.rb" require "e2mmap.rb" # # This class watches for termination of multiple threads. Basic functionality # (wait until specified threads have terminated) can be accessed through the # class method ThreadsWait::all_waits. Finer control can be gained using # instance methods. # # Example: # # ThreadsWait.all_waits(thr1, thr2, ...) do |t| # STDERR.puts "Thread #{t} has terminated." # end # # # th = ThreadsWait.new(thread1,...) # th.next_wait # next one to be done # # class ThreadsWait extend Exception2MessageMapper def_exception("ErrNoWaitingThread", "No threads for waiting.") def_exception("ErrNoFinishedThread", "No finished threads.") # # Waits until all specified threads have terminated. If a block is provided, # it is executed for each thread as they terminate. # def ThreadsWait.all_waits(*threads) # :yield: thread tw = ThreadsWait.new(*threads) if block_given? tw.all_waits do |th| yield th end else tw.all_waits end end # # Creates a ThreadsWait object, specifying the threads to wait on. # Non-blocking. # def initialize(*threads) @threads = [] @wait_queue = Thread::Queue.new join_nowait(*threads) unless threads.empty? end # Returns the array of threads that have not terminated yet. attr_reader :threads # # Returns +true+ if there are no threads in the pool still running. # def empty? @threads.empty? end # # Returns +true+ if any thread has terminated and is ready to be collected. # def finished? !@wait_queue.empty? end # # Waits for specified threads to terminate, and returns when one of # the threads terminated. # def join(*threads) join_nowait(*threads) next_wait end # # Specifies the threads that this object will wait for, but does not actually # wait. # def join_nowait(*threads) threads.flatten! @threads.concat threads for th in threads Thread.start(th) do |t| begin t.join ensure @wait_queue.push t end end end end # # Waits until any of the specified threads has terminated, and returns the one # that does. # # If there is no thread to wait, raises +ErrNoWaitingThread+. If +nonblock+ # is true, and there is no terminated thread, raises +ErrNoFinishedThread+. # def next_wait(nonblock = nil) ThreadsWait.fail ErrNoWaitingThread if @threads.empty? begin @threads.delete(th = @wait_queue.pop(nonblock)) th rescue ThreadError ThreadsWait.fail ErrNoFinishedThread end end # # Waits until all of the specified threads are terminated. If a block is # supplied for the method, it is executed for each thread termination. # # Raises exceptions in the same manner as +next_wait+. # def all_waits until @threads.empty? th = next_wait yield th if block_given? end end end ## # An alias for ThreadsWait from thwait.rb ThWait = ThreadsWait # Documentation comments: # - Source of documentation is evenly split between Nutshell, existing # comments, and my own rephrasing. # - I'm not particularly confident that the comments are all exactly correct.

---

docroot: /home/induvedam/public_html

---

curdir: /opt/alt/ruby24/lib64/ruby/2.4.0

	.		4096
	..		31
X	English.rb		6607
X	abbrev.rb		3576
X	base64.rb		3386
X	benchmark.rb		18328
	cgi		101
X	cgi.rb		10039
X	cmath.rb		9705
X	csv.rb		85536
X	date.rb		1004
X	debug.rb		30695
X	delegate.rb		10553
	digest		21
X	digest.rb		2894
	drb		190
X	drb.rb		50
X	e2mmap.rb		4039
X	erb.rb		27900
X	expect.rb		2226
	fiddle		142
X	fiddle.rb		1723
X	fileutils.rb		45113
X	find.rb		2576
	forwardable		21
X	forwardable.rb		8708
X	getoptlong.rb		15779
	io		21
X	ipaddr.rb		17510
	irb		4096
X	irb.rb		20776
	json		91
X	json.rb		1809
X	kconv.rb		5906
X	logger.rb		24099
X	mathn.rb		3506
	matrix		69
X	matrix.rb		54647
X	mkmf.rb		86346
X	monitor.rb		7188
X	mutex_m.rb		2089
	net		126
X	observer.rb		5972
X	open-uri.rb		25358
X	open3.rb		21089
	openssl		134
X	openssl.rb		445
X	optionparser.rb		59
	optparse		119
X	optparse.rb		58624
X	ostruct.rb		10446
X	pathname.rb		16464
X	pp.rb		14777
X	prettyprint.rb		16276
X	prime.rb		12790
X	profile.rb		236
X	profiler.rb		4648
X	pstore.rb		15058
	psych		4096
X	psych.rb		15615
	racc		35
	rbconfig		24
	rdoc		4096
X	rdoc.rb		5187
X	resolv-replace.rb		1805
X	resolv.rb		75243
	rexml		4096
	rinda		58
	ripper		69
X	ripper.rb		2617
	rss		4096
X	rss.rb		2940
	rubygems		4096
X	rubygems.rb		36227
X	scanf.rb		24123
X	securerandom.rb		7663
X	set.rb		21233
	shell		165
X	shell.rb		11644
X	shellwords.rb		6817
X	singleton.rb		4153
X	socket.rb		44022
X	sync.rb		7470
	syslog		23
X	tempfile.rb		11061
X	thwait.rb		3431
X	time.rb		22892
X	timeout.rb		3917
X	tmpdir.rb		4398
X	tracer.rb		6595
X	tsort.rb		14642
X	ubygems.rb		298
X	un.rb		9396
	unicode_normalize		43
X	unicode_normalize.rb		3273
	uri		184
X	uri.rb		3174
X	weakref.rb		3017
	webrick		4096
X	webrick.rb		6881
	x86_64-linux		4096
	yaml		36
X	yaml.rb		1772