?HAMA

Navigation

Breadcrumbs

/ / proc / thread-self / root / opt / alt / ruby18 / lib64 / ruby / 1.8

Create

Create File | Create Folder | Upload Files | Run Command

Edit File Size: 7.93 KB

//proc/thread-self/root/opt/alt/ruby18/lib64/ruby/1.8/monitor.rb

Text Base64

=begin

= monitor.rb

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

#
# Adds monitor functionality to an arbitrary object by mixing the module with
# +include+.  For 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.
#
module MonitorMixin
  #
  # FIXME: This isn't documented in Nutshell.
  #
  # Since MonitorMixin.new_cond returns a ConditionVariable, and the example
  # above calls while_wait and signal, this class should be documented.
  #
  class ConditionVariable
    class Timeout < Exception; end
    
    # Create a new timer with the argument timeout, and add the
    # current thread to the list of waiters.  Then the thread is
    # stopped.  It will be resumed when a corresponding #signal 
    # occurs.
    def wait(timeout = nil)
      @monitor.instance_eval {mon_check_owner()}
      timer = create_timer(timeout)
      
      Thread.critical = true
      count = @monitor.instance_eval {mon_exit_for_cond()}
      @waiters.push(Thread.current)

begin
	Thread.stop
        return true
      rescue Timeout
        return false
      ensure
	Thread.critical = true
	begin
	  if timer && timer.alive?
	    Thread.kill(timer)
	  end
	  if @waiters.include?(Thread.current)  # interrupted?
	    @waiters.delete(Thread.current)
	  end
	  @monitor.instance_eval {mon_enter_for_cond(count)}
	ensure
	  Thread.critical = false
	end
      end
    end

# call #wait while the supplied block returns +true+.
    def wait_while
      while yield
	wait
      end
    end
    
    # call #wait until the supplied block returns +true+.
    def wait_until
      until yield
	wait
      end
    end
    
    # Wake up and run the next waiter
    def signal
      @monitor.instance_eval {mon_check_owner()}
      Thread.critical = true
      t = @waiters.shift
      t.wakeup if t
      Thread.critical = false
      Thread.pass
    end
    
    # Wake up all the waiters.
    def broadcast
      @monitor.instance_eval {mon_check_owner()}
      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

def create_timer(timeout)
      if timeout
	waiter = Thread.current
	return Thread.start {
	  Thread.pass
	  sleep(timeout)
	  Thread.critical = true
	  waiter.raise(Timeout.new)
	}
      else
        return nil
      end
    end
  end
  
  def self.extend_object(obj)
    super(obj)
    obj.instance_eval {mon_initialize()}
  end
  
  #
  # Attempts to enter exclusive section.  Returns +false+ if lock fails.
  #
  def mon_try_enter
    result = false
    Thread.critical = true
    if @mon_owner.nil?
      @mon_owner = Thread.current
    end
    if @mon_owner == Thread.current
      @mon_count += 1
      result = true
    end
    Thread.critical = false
    return result
  end
  # For backward compatibility
  alias try_mon_enter mon_try_enter

#
  # Enters exclusive section.
  #
  def mon_enter
    Thread.critical = true
    mon_acquire(@mon_entering_queue)
    @mon_count += 1
  ensure
    Thread.critical = false
  end
  
  #
  # Leaves exclusive section.
  #
  def mon_exit
    mon_check_owner
    Thread.critical = true
    @mon_count -= 1
    if @mon_count == 0
      mon_release
    end
    Thread.critical = false
    Thread.pass
  end

#
  # Enters exclusive section and executes the block.  Leaves the exclusive
  # section automatically when the block exits.  See example under
  # +MonitorMixin+.
  #
  def mon_synchronize
    mon_enter
    begin
      yield
    ensure
      mon_exit
    end
  end
  alias synchronize mon_synchronize
  
  #
  # FIXME: This isn't documented in Nutshell.
  # 
  # Create a new condition variable for this monitor.
  # This facilitates control of the monitor with #signal and #wait.
  #
  def new_cond
    return ConditionVariable.new(self)
  end

private

def initialize(*args)
    super
    mon_initialize
  end

# called by initialize method to set defaults for instance variables.
  def mon_initialize
    @mon_owner = nil
    @mon_count = 0
    @mon_entering_queue = []
    @mon_waiting_queue = []
  end

# Throw a ThreadError exception if the current thread
  # does't own the monitor
  def mon_check_owner
    if @mon_owner != Thread.current
      raise ThreadError, "current thread not owner"
    end
  end

def mon_acquire(queue)
    while @mon_owner && @mon_owner != Thread.current
      queue.push(Thread.current)
      Thread.stop
      Thread.critical = true
    end
    @mon_owner = Thread.current
  end

# mon_release requires Thread.critical == true
  def mon_release
    @mon_owner = nil
    while t = @mon_waiting_queue.shift || @mon_entering_queue.shift
      if t.alive?
        t.wakeup
        return
      end
    end
  end

def mon_enter_for_cond(count)
    mon_acquire(@mon_waiting_queue)
    @mon_count = count
  end

def mon_exit_for_cond
    count = @mon_count
    @mon_count = 0
    return count
  ensure
    mon_release
  end
end

# Monitors provide means of mutual exclusion for Thread programming.
# A critical region is created by means of the synchronize method,
# which takes a block.
# The condition variables (created with #new_cond) may be used 
# to control the execution of a monitor with #signal and #wait.
#
# the Monitor class wraps MonitorMixin, and provides aliases
#  alias try_enter try_mon_enter
#  alias enter mon_enter
#  alias exit mon_exit
# to access its methods more concisely.
class Monitor
  include MonitorMixin
  alias try_enter try_mon_enter
  alias enter mon_enter
  alias exit mon_exit
end

# Documentation comments:
#  - All documentation comes from Nutshell.
#  - MonitorMixin.new_cond appears in the example, but is not documented in
#    Nutshell.
#  - All the internals (internal modules Accessible and Initializable, class
#    ConditionVariable) appear in RDoc.  It might be good to hide them, by
#    making them private, or marking them :nodoc:, etc.
#  - The entire example from the RD section at the top is replicated in the RDoc
#    comment for MonitorMixin.  Does the RD section need to remain?
#  - RDoc doesn't recognise aliases, so we have mon_synchronize documented, but
#    not synchronize.
#  - mon_owner is in Nutshell, but appears as an accessor in a separate module
#    here, so is hard/impossible to RDoc.  Some other useful accessors
#    (mon_count and some queue stuff) are also in this module, and don't appear
#    directly in the RDoc output.
#  - in short, it may be worth changing the code layout in this file to make the
#    documentation easier

# Local variables:
# mode: Ruby
# tab-width: 8
# End:

Exit & Reset Text mode: syntax highlighting auto-detects file type.

Directory Contents

Dirs: 27 × Files: 83

Sort:

Enable drag-to-move

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