Gecko [ beriskala.com ]

Name	Size	Permission	Date
bigdecimal	[ DIR ]	drwxr-xr-x	2026-04-30 23:44
cgi	[ DIR ]	drwxr-xr-x	2026-04-30 23:44
date	[ DIR ]	drwxr-xr-x	2026-04-30 23:44
digest	[ DIR ]	drwxr-xr-x	2026-04-30 23:44
dl	[ DIR ]	drwxr-xr-x	2026-04-30 23:44
drb	[ DIR ]	drwxr-xr-x	2026-04-30 23:44
io	[ DIR ]	drwxr-xr-x	2026-04-30 23:44
irb	[ DIR ]	drwxr-xr-x	2026-04-30 23:44
net	[ DIR ]	drwxr-xr-x	2026-04-30 23:44
openssl	[ DIR ]	drwxr-xr-x	2026-04-30 23:44
optparse	[ DIR ]	drwxr-xr-x	2026-04-30 23:44
racc	[ DIR ]	drwxr-xr-x	2026-04-30 23:44
rdoc	[ DIR ]	drwxr-xr-x	2026-04-30 23:44
rexml	[ DIR ]	drwxr-xr-x	2026-04-30 23:44
rinda	[ DIR ]	drwxr-xr-x	2026-04-30 23:44
rss	[ DIR ]	drwxr-xr-x	2026-04-30 23:44
runit	[ DIR ]	drwxr-xr-x	2026-04-30 23:44
shell	[ DIR ]	drwxr-xr-x	2026-04-30 23:44
soap	[ DIR ]	drwxr-xr-x	2026-04-30 23:44
test	[ DIR ]	drwxr-xr-x	2026-04-30 23:44
uri	[ DIR ]	drwxr-xr-x	2026-04-30 23:44
webrick	[ DIR ]	drwxr-xr-x	2026-04-30 23:44
wsdl	[ DIR ]	drwxr-xr-x	2026-04-30 23:44
x86_64-linux	[ DIR ]	drwxr-xr-x	2026-04-30 23:44
xmlrpc	[ DIR ]	drwxr-xr-x	2026-04-30 23:44
xsd	[ DIR ]	drwxr-xr-x	2026-04-30 23:44
yaml	[ DIR ]	drwxr-xr-x	2026-04-30 23:44
English.rb	5.6 KB	-rw-r--r--	2007-02-13 02:31
Env.rb	274 B	-rw-r--r--	2007-02-13 02:31
abbrev.rb	2.5 KB	-rw-r--r--	2007-02-13 02:31
base64.rb	3.37 KB	-rw-r--r--	2007-07-16 19:17
benchmark.rb	17.73 KB	-rw-r--r--	2008-02-10 18:54
cgi-lib.rb	6.89 KB	-rw-r--r--	2007-02-13 02:31
cgi.rb	73.74 KB	-rw-r--r--	2009-12-14 06:10
complex.rb	12.84 KB	-rw-r--r--	2009-08-03 10:29
csv.rb	24.46 KB	-rw-r--r--	2007-02-13 02:31
date.rb	53.02 KB	-rw-r--r--	2010-06-08 09:15
date2.rb	128 B	-rw-r--r--	2007-02-13 02:31
debug.rb	20.61 KB	-rw-r--r--	2007-02-13 02:31
delegate.rb	8.81 KB	-rw-r--r--	2009-07-16 05:05
digest.rb	1.12 KB	-rw-r--r--	2007-07-28 04:10
drb.rb	19 B	-rw-r--r--	2007-02-13 02:31
e2mmap.rb	4.04 KB	-rw-r--r--	2007-02-13 02:31
erb.rb	21.38 KB	-rw-r--r--	2009-02-23 21:14
eregex.rb	487 B	-rw-r--r--	2007-02-13 02:31
expect.rb	633 B	-rw-r--r--	2008-02-18 04:47
fileutils.rb	42.23 KB	-rw-r--r--	2011-05-21 02:59
finalize.rb	5.38 KB	-rw-r--r--	2007-02-13 02:31
find.rb	1.84 KB	-rw-r--r--	2007-02-13 02:31
forwardable.rb	6.16 KB	-rw-r--r--	2008-06-06 12:35
ftools.rb	6.17 KB	-rw-r--r--	2007-02-13 02:31
generator.rb	8.1 KB	-rw-r--r--	2008-04-10 15:22
getoptlong.rb	14.88 KB	-rw-r--r--	2007-02-13 02:31
getopts.rb	2.25 KB	-rw-r--r--	2007-02-13 02:31
gserver.rb	6.43 KB	-rw-r--r--	2007-02-13 02:31
importenv.rb	590 B	-rw-r--r--	2007-02-13 02:31
ipaddr.rb	21.96 KB	-rw-r--r--	2008-07-12 19:38
irb.rb	7.43 KB	-rw-r--r--	2009-08-09 13:14
jcode.rb	4.3 KB	-rw-r--r--	2007-02-13 02:31
kconv.rb	8.12 KB	-rw-r--r--	2007-02-13 02:31
logger.rb	17.59 KB	-rw-r--r--	2011-05-30 06:38
mailread.rb	1.28 KB	-rw-r--r--	2007-02-13 02:31
mathn.rb	5.42 KB	-rw-r--r--	2007-02-13 02:31
matrix.rb	27.21 KB	-rw-r--r--	2009-01-24 18:32
md5.rb	411 B	-rw-r--r--	2007-03-06 13:39
mkmf.rb	50.65 KB	-rw-r--r--	2010-12-04 10:04
monitor.rb	7.93 KB	-rw-r--r--	2009-11-25 11:15
mutex_m.rb	2.07 KB	-rw-r--r--	2007-02-13 02:31
observer.rb	5.15 KB	-rw-r--r--	2007-02-13 02:31
open-uri.rb	20.49 KB	-rw-r--r--	2007-10-08 14:46
open3.rb	2.1 KB	-rw-r--r--	2009-12-14 07:58
openssl.rb	575 B	-rw-r--r--	2010-11-22 10:51
optparse.rb	47.12 KB	-rw-r--r--	2009-02-20 15:13
ostruct.rb	3.35 KB	-rw-r--r--	2009-05-26 16:36
parsearg.rb	1.55 KB	-rw-r--r--	2007-02-13 02:31
parsedate.rb	1.33 KB	-rw-r--r--	2007-02-13 02:31
pathname.rb	29.39 KB	-rw-r--r--	2010-11-23 11:51
ping.rb	1.48 KB	-rw-r--r--	2007-02-13 02:31
pp.rb	15.97 KB	-rw-r--r--	2007-06-07 13:36
prettyprint.rb	18.33 KB	-rw-r--r--	2007-02-16 23:23
profile.rb	90 B	-rw-r--r--	2007-02-13 02:31
profiler.rb	1.59 KB	-rw-r--r--	2007-02-13 02:31
pstore.rb	11.15 KB	-rw-r--r--	2008-06-06 12:35
rational.rb	12.05 KB	-rw-r--r--	2010-06-08 09:32
readbytes.rb	835 B	-rw-r--r--	2007-02-13 02:31
resolv-replace.rb	1.55 KB	-rw-r--r--	2008-08-08 06:28
resolv.rb	56.83 KB	-rw-r--r--	2010-12-23 06:52
rss.rb	504 B	-rw-r--r--	2007-10-21 15:49
rubyunit.rb	180 B	-rw-r--r--	2007-02-13 02:31
scanf.rb	20.63 KB	-rw-r--r--	2009-01-20 06:53
securerandom.rb	4.27 KB	-rw-r--r--	2011-12-10 15:47
set.rb	27.08 KB	-rw-r--r--	2008-06-09 13:50
sha1.rb	418 B	-rw-r--r--	2007-03-06 13:39
shell.rb	4.66 KB	-rw-r--r--	2007-02-13 02:31
shellwords.rb	3.99 KB	-rw-r--r--	2008-03-21 16:46
singleton.rb	8.08 KB	-rw-r--r--	2008-07-03 15:44
sync.rb	6.09 KB	-rw-r--r--	2009-02-19 20:11
tempfile.rb	4.86 KB	-rw-r--r--	2008-04-21 14:13
thread.rb	104 B	-rw-r--r--	2007-02-13 23:09
thwait.rb	4.32 KB	-rw-r--r--	2010-06-08 11:38
time.rb	31.58 KB	-rw-r--r--	2008-06-06 12:35
timeout.rb	3 KB	-rw-r--r--	2010-06-08 10:54
tmpdir.rb	3.69 KB	-rw-r--r--	2009-01-26 05:42
tracer.rb	2.73 KB	-rw-r--r--	2007-02-13 02:31
tsort.rb	7.99 KB	-rw-r--r--	2007-02-13 02:31
un.rb	4.54 KB	-rw-r--r--	2007-02-13 02:31
uri.rb	710 B	-rw-r--r--	2008-04-15 14:11
weakref.rb	2.68 KB	-rw-r--r--	2007-02-13 02:31
webrick.rb	811 B	-rw-r--r--	2007-02-13 02:31
yaml.rb	12.36 KB	-rw-r--r--	2008-04-19 16:15

Rename

#
#   thwait.rb - thread synchronization class
#   	$Release Version: 0.9 $
#   	$Revision: 1.3 $
#   	$Date: 1998/06/26 03:19:34 $
#   	by Keiju ISHITSUKA(Nihpon Rational Software Co.,Ltd.)
#
# --
#  feature:
#  provides synchronization for multiple threads.
#
#  class methods:
#  * ThreadsWait.all_waits(thread1,...)
#    waits until all of specified threads are terminated.
#    if a block is supplied for the method, evaluates it for
#    each thread termination.
#  * th = ThreadsWait.new(thread1,...)
#    creates synchronization object, specifying thread(s) to wait.
#  
#  methods:
#  * th.threads
#    list threads to be synchronized
#  * th.empty?
#    is there any thread to be synchronized.
#  * th.finished?
#    is there already terminated thread.
#  * th.join(thread1,...) 
#    wait for specified thread(s).
#  * th.join_nowait(threa1,...)
#    specifies thread(s) to wait.  non-blocking.
#  * th.next_wait
#    waits until any of specified threads is terminated.
#  * th.all_waits
#    waits until all of specified threads are terminated.
#    if a block is supplied for the method, evaluates it for
#    each thread termination.
#

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_wait(thr1, thr2, ...) do |t|
#     STDERR.puts "Thread #{t} has terminated."
#   end
#
class ThreadsWait
  RCS_ID='-$Id: thwait.rb,v 1.3 1998/06/26 03:19:34 keiju Exp keiju $-'
  
  Exception2MessageMapper.extend_to(binding)
  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 termination.
  #
  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 = Queue.new
    join_nowait(*threads) unless threads.empty?
  end
  
  # Returns the array of threads in the wait queue.
  attr :threads
  
  #
  # Returns +true+ if there are no threads to be synchronized.
  #
  def empty?
    @threads.empty?
  end
  
  #
  # Returns +true+ if any thread has terminated.
  #
  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

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.
#  - The history, etc., up the top appears in the RDoc output.  Perhaps it would
#    be better to direct that not to appear, and put something else there
#    instead.