1 files changed, 128 insertions, 0 deletions
diff --git a/lib/thwait.rb b/lib/thwait.rb
new file mode 100644
index 0000000000..c638335f5d
--- /dev/null
+++ b/lib/thwait.rb
@@ -0,0 +1,128 @@
+#
+#   thwait.rb - 
+#   	$Release Version: $
+#   	$Revision: 1.1 $
+#   	$Date: 1997/08/18 03:13:14 $
+#   	by Keiju ISHITSUKA(Nippon Rational Inc.)
+#
+# --
+#
+#   
+#
+
+require "thread.rb"
+require "e2mmap.rb"
+
+class ThreadsWait
+  RCS_ID='-$Header: /home/keiju/var/src/var.lib/ruby/RCS/thwait.rb,v 1.1 1997/08/18 03:13:14 keiju Exp keiju $-'
+  
+  Exception2MessageMapper.extend_to(binding)
+  def_exception("ErrWaitThreadsNothing", "Wait threads nothing.")
+  def_exception("FinshedThreadsNothing", "finished thread nothing.")
+  
+  # class mthods
+  #	all_waits
+  
+  #
+  # ���ꤷ������åɤ����ƽ�λ����ޤ��Ԥ�. ���ƥ졼���Ȥ��ƸƤФ���
+  # ���ꤷ������åɤ���λ����ȥ��ƥ졼����ƤӽФ�.
+  #
+  def ThreadsWait.all_waits(*threads)
+    tw = ThreadsWait.new(th1, th2, th3, th4, th5)
+    if iterator?
+      tw.all_waits do
+	|th|
+	yield th
+      end
+    else
+      tw.all_waits
+    end
+  end
+  
+  # initialize and terminating:
+  #	initialize
+  
+  #
+  # �����. �Ԥĥ���åɤλ��꤬�Ǥ���.
+  #
+  def initialize(*threads)
+    @threads = []
+    @wait_queue = Queue.new
+    join_nowait(*threads) unless threads.empty?
+  end
+  
+  # accessing
+  #	threads
+  
+  # �Ԥ�����åɤΰ������֤�.
+  attr :threads
+  
+  # testing
+  #	empty?
+  #	finished?
+  #
+  
+  #
+  # �Ԥ�����åɤ�¸�ߤ��뤫�ɤ������֤�.
+  def empty?
+    @threads.empty?
+  end
+  
+  #
+  # ���Ǥ˽�λ��������åɤ����뤫�ɤ����֤�
+  def finished?
+    !@wait_queue.empty?
+  end
+  
+  # main process:
+  #	join
+  #	join_nowait
+  #	next_wait
+  #	all_wait
+  
+  #
+  # �ԤäƤ��륹��åɤ��ɲä��Ԥ��ˤϤ���.
+  #
+  def join(*threads)
+    join_nowait(*threads)
+    next_wait
+  end
+  
+  #
+  # �ԤäƤ��륹��åɤ��ɲä���. �Ԥ��ˤ�����ʤ�.
+  #
+  def join_nowait(*threads)
+    @threads.concat threads
+    for th in threads
+      Thread.start do
+	th = Thread.join(th)
+	@wait_queue.push th
+      end
+    end
+  end
+  
+  #
+  # �����Ԥ��ˤϤ���.
+  # �ԤĤ٤�����åɤ��ʤ����, �㳰ErrWaitThreadsNothing ���֤�.
+  # nonnlock�����λ��ˤ�, nonblocking��Ĵ�٤�. ¸�ߤ��ʤ����, �㳰
+  # FinishedThreadNothing���֤�.
+  #
+  def next_wait(nonblock = nil)
+    Threads.Wait.fail ErrWaitThreadsNothing if @threads.empty?
+    
+    th = @wait_queue.pop(nonblock)
+    @threads.delete th
+    th
+  end
+  
+  #
+  # ���ƤΥ���åɤ���λ����ޤ��Ԥ�. ���ƥ졼���Ȥ��ƸƤФ줿����, ��
+  # ��åɤ���λ�����٤�, ���ƥ졼����ƤӽФ�.
+  #
+  def all_waits
+    until @threads.empty?
+      th = next_wait
+      yield th if iterator?
+    end
+  end
+end