diff options
Diffstat (limited to 'lib/thread.rb')
| -rw-r--r-- | lib/thread.rb | 274 |
1 files changed, 0 insertions, 274 deletions
diff --git a/lib/thread.rb b/lib/thread.rb deleted file mode 100644 index d4b6ad6ec1..0000000000 --- a/lib/thread.rb +++ /dev/null @@ -1,274 +0,0 @@ -# -# thread.rb - thread support classes -# $Date$ -# by Yukihiro Matsumoto <matz@netlab.co.jp> -# -# Copyright (C) 2000 Network Applied Communication Laboratory, Inc. -# Copyright (C) 2000 Information-technology Promotion Agency, Japan -# - -unless defined? Thread - fail "Thread not available for this ruby interpreter" -end - -unless defined? ThreadError - class ThreadError<StandardError - end -end - -if $DEBUG - Thread.abort_on_exception = true -end - -def Thread.exclusive - _old = Thread.critical - begin - Thread.critical = true - return yield - ensure - Thread.critical = _old - end -end - -class Mutex - def initialize - @waiting = [] - @locked = false; - @waiting.taint # enable tainted comunication - self.taint - 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 - @locked = false - begin - t = @waiting.shift - t.wakeup if t - rescue ThreadError - retry - end - Thread.critical = false - t.run if t - self - end - - def synchronize - lock - begin - yield - ensure - unlock - end - end - - def exclusive_unlock - return unless @locked - Thread.exclusive do - @locked = false - begin - t = @waiting.shift - t.wakeup if t - rescue ThreadError - retry - end - yield - end - self - end -end - -class ConditionVariable - def initialize - @waiters = [] - end - - def wait(mutex) - mutex.exclusive_unlock do - @waiters.push(Thread.current) - Thread.stop - end - mutex.lock - end - - def signal - begin - t = @waiters.shift - t.run if t - rescue ThreadError - retry - end - end - - def broadcast - waiters0 = nil - Thread.exclusive do - waiters0 = @waiters.dup - @waiters.clear - end - for t in waiters0 - begin - t.run - rescue ThreadError - end - end - end -end - -class Queue - def initialize - @que = [] - @waiting = [] - @que.taint # enable tainted comunication - @waiting.taint - self.taint - end - - def push(obj) - Thread.critical = true - @que.push obj - begin - t = @waiting.shift - t.wakeup if t - rescue ThreadError - retry - ensure - Thread.critical = false - end - t.run if t - end - def enq(obj) - push(obj) - end - - def pop(non_block=false) - Thread.critical = true - begin - loop do - if @que.length == 0 - if non_block - raise ThreadError, "queue empty" - end - @waiting.push Thread.current - Thread.stop - else - return @que.shift - end - end - ensure - Thread.critical = false - end - end - def shift(non_block=false) - pop(non_block=false) - end - alias deq shift - - def empty? - @que.length == 0 - end - - def clear - @que.replace([]) - end - - def length - @que.length - end - def size - length - end - - def num_waiting - @waiting.size - end -end - -class SizedQueue<Queue - def initialize(max) - @max = max - @queue_wait = [] - @queue_wait.taint # enable tainted comunication - super() - end - - def max - @max - end - - def max=(max) - Thread.critical = true - if max >= @max - @max = max - Thread.critical = false - else - diff = max - @max - @max = max - Thread.critical = false - diff.times do - begin - t = @queue_wait.shift - t.run if t - rescue ThreadError - retry - end - end - end - max - end - - def push(obj) - Thread.critical = true - while @que.length >= @max - @queue_wait.push Thread.current - Thread.stop - Thread.critical = true - end - super - end - - def pop(*args) - Thread.critical = true - if @que.length < @max - begin - t = @queue_wait.shift - t.wakeup if t - rescue ThreadError - retry - ensure - Thread.critical = false - end - t.run if t - end - super - end - - def num_waiting - @waiting.size + @queue_wait.size - end -end |