diff options
Diffstat (limited to 'lib/monitor.rb')
| -rw-r--r-- | lib/monitor.rb | 249 |
1 files changed, 0 insertions, 249 deletions
diff --git a/lib/monitor.rb b/lib/monitor.rb deleted file mode 100644 index 721c51a9f5..0000000000 --- a/lib/monitor.rb +++ /dev/null @@ -1,249 +0,0 @@ -=begin - -= monitor.rb - -Copyright (C) 2001 Shugo Maeda <shugo@ruby-lang.org> - -This library is distributed under the terms of the Ruby license. -You can freely distribute/modify this library. - -== example - -This is a simple example. - - require 'monitor.rb' - - buf = [] - buf.extend(MonitorMixin) - empty_cond = buf.new_cond - - # consumer - Thread.start do - loop do - buf.synchronize do - empty_cond.wait_while { buf.empty? } - print buf.shift - end - end - end - - # producer - while line = ARGF.gets - buf.synchronize do - buf.push(line) - empty_cond.signal - end - end - -The consumer thread waits for the producer thread to push a line -to buf while buf.empty?, and the producer thread (main thread) -reads a line from ARGF and push it to buf, then call -empty_cond.signal. - -=end - -module MonitorMixin - module Accessible - protected - attr_accessor :mon_owner, :mon_count - attr_reader :mon_entering_queue, :mon_waiting_queue - end - - module Initializable - protected - def mon_initialize - @mon_owner = nil - @mon_count = 0 - @mon_entering_queue = [] - @mon_waiting_queue = [] - end - end - - class ConditionVariable - class Timeout < Exception; end - - include Accessible - - def wait(timeout = nil) - if @monitor.mon_owner != Thread.current - raise ThreadError, "current thread not owner" - end - - if timeout - ct = Thread.current - timeout_thread = Thread.start { - Thread.pass - sleep(timeout) - ct.raise(Timeout.new) - } - end - - Thread.critical = true - count = @monitor.mon_count - @monitor.mon_count = 0 - @monitor.mon_owner = nil - if @monitor.mon_waiting_queue.empty? - t = @monitor.mon_entering_queue.shift - else - t = @monitor.mon_waiting_queue.shift - end - t.wakeup if t - @waiters.push(Thread.current) - - begin - Thread.stop - rescue Timeout - ensure - Thread.critical = true - if timeout && timeout_thread.alive? - Thread.kill(timeout_thread) - end - if @waiters.include?(Thread.current) # interrupted? - @waiters.delete(Thread.current) - end - while @monitor.mon_owner && - @monitor.mon_owner != Thread.current - @monitor.mon_waiting_queue.push(Thread.current) - Thread.stop - Thread.critical = true - end - @monitor.mon_owner = Thread.current - @monitor.mon_count = count - Thread.critical = false - end - end - - def wait_while - while yield - wait - end - end - - def wait_until - until yield - wait - end - end - - def signal - if @monitor.mon_owner != Thread.current - raise ThreadError, "current thread not owner" - end - Thread.critical = true - t = @waiters.shift - t.wakeup if t - Thread.critical = false - Thread.pass - end - - def broadcast - if @monitor.mon_owner != Thread.current - raise ThreadError, "current thread not owner" - end - Thread.critical = true - for t in @waiters - t.wakeup - end - @waiters.clear - Thread.critical = false - Thread.pass - end - - def count_waiters - return @waiters.length - end - - private - def initialize(monitor) - @monitor = monitor - @waiters = [] - end - end - - include Accessible - include Initializable - extend Initializable - - def self.extend_object(obj) - super(obj) - obj.mon_initialize - end - - def try_mon_enter - result = false - Thread.critical = true - if mon_owner.nil? - self.mon_owner = Thread.current - end - if mon_owner == Thread.current - self.mon_count += 1 - result = true - end - Thread.critical = false - return result - end - - def mon_enter - Thread.critical = true - while mon_owner != nil && mon_owner != Thread.current - mon_entering_queue.push(Thread.current) - Thread.stop - Thread.critical = true - end - self.mon_owner = Thread.current - self.mon_count += 1 - Thread.critical = false - end - - def mon_exit - if mon_owner != Thread.current - raise ThreadError, "current thread not owner" - end - Thread.critical = true - self.mon_count -= 1 - if mon_count == 0 - self.mon_owner = nil - if mon_waiting_queue.empty? - t = mon_entering_queue.shift - else - t = mon_waiting_queue.shift - end - end - t.wakeup if t - Thread.critical = false - Thread.pass - end - - def mon_synchronize - mon_enter - begin - yield - ensure - mon_exit - end - end - alias synchronize mon_synchronize - - def new_cond - return ConditionVariable.new(self) - end - -private - def initialize(*args) - super - mon_initialize - end -end - -class Monitor - include MonitorMixin - alias try_enter try_mon_enter - alias enter mon_enter - alias exit mon_exit - alias owner mon_owner -end - -# Local variables: -# mode: Ruby -# tab-width: 8 -# End: |