From 99d0354e89aefdb6373dbeb22506216b8790a0bd Mon Sep 17 00:00:00 2001
From: matz <matz@b2dd03c8-39d4-4d8f-98ff-823fe69b080e>
Date: Fri, 16 Jan 1998 12:13:05 +0000
Subject: Initial revision

git-svn-id: http://svn.ruby-lang.org/repos/ruby/trunk@2 b2dd03c8-39d4-4d8f-98ff-823fe69b080e
---
 lib/thread.rb | 110 ++++++++++++++++++++++++++++++++++++++++++++++++++++++++++
 1 file changed, 110 insertions(+)
 create mode 100644 lib/thread.rb

(limited to 'lib/thread.rb')

diff --git a/lib/thread.rb b/lib/thread.rb
new file mode 100644
index 000000000..4f294cc9a
--- /dev/null
+++ b/lib/thread.rb
@@ -0,0 +1,110 @@
+#
+#		thread.rb - thread support classes
+#			$Date$
+#			by Yukihiro Matsumoto <matz@caelum.co.jp>
+#
+
+unless defined? Thread
+  fail "Thread not available for this ruby interpreter"
+end
+
+unless defined? ThreadError
+  class ThreadError<Exception
+  end
+end
+
+class Mutex
+  def initialize
+    @waiting = []
+    @locked = FALSE;
+  end
+
+  def locked?
+    @locked
+  end
+
+  def try_lock
+    result = FALSE
+    Thread.critical = TRUE
+    unless @locked
+      @locked = TRUE
+      result = TRUE
+    end
+    Thread.critical = FALSE
+    result
+  end
+
+  def lock
+    while (Thread.critical = TRUE; @locked)
+      @waiting.push Thread.current
+      Thread.stop
+    end
+    @locked = TRUE
+    Thread.critical = FALSE
+    self
+  end
+
+  def unlock
+    return unless @locked
+    Thread.critical = TRUE
+    wait = @waiting
+    @waiting = []
+    @locked = FALSE
+    Thread.critical = FALSE
+    for w in wait
+      w.run
+    end
+    self
+  end
+
+  def synchronize
+    begin
+      lock
+      yield
+    ensure
+      unlock
+    end
+  end
+end
+
+class Queue
+  def initialize
+    @que = []
+    @waiting = []
+  end
+
+  def push(obj)
+    Thread.critical = TRUE
+    @que.push obj
+    t = @waiting.shift
+    Thread.critical = FALSE
+    t.run if t
+  end
+
+  def pop non_block=FALSE
+    item = nil
+    until item
+      Thread.critical = TRUE
+      if @que.length == 0
+	if non_block
+	  Thread.critical = FALSE
+	  raise ThreadError, "queue empty"
+	end
+	@waiting.push Thread.current
+	Thread.stop
+      else
+	item = @que.shift
+      end
+    end
+    Thread.critical = FALSE
+    item
+  end
+
+  def empty?
+    @que.length == 0
+  end
+
+  def length
+    @que.length
+  end
+end
-- 
cgit