Gecko [ www.corporacionhdm.com.pe ]

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

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.