mirror of
				https://github.com/ruby/ruby.git
				synced 2022-11-09 12:17:21 -05:00 
			
		
		
		
	 85d105cf8c
			
		
	
	
		85d105cf8c
		
	
	
	
	
		
			
			obj.extend(Sync_m) * lib/mutex_m.rb: modified bit git-svn-id: svn+ssh://ci.ruby-lang.org/ruby/trunk@1513 b2dd03c8-39d4-4d8f-98ff-823fe69b080e
		
			
				
	
	
		
			311 lines
		
	
	
	
		
			6 KiB
		
	
	
	
		
			Ruby
		
	
	
	
	
	
			
		
		
	
	
			311 lines
		
	
	
	
		
			6 KiB
		
	
	
	
		
			Ruby
		
	
	
	
	
	
| #
 | |
| #   sync.rb - 2 phase lock with counter
 | |
| #   	$Release Version: 1.0$
 | |
| #   	$Revision$
 | |
| #   	$Date$
 | |
| #   	by Keiju ISHITSUKA(keiju@ishitsuka.com)
 | |
| #
 | |
| # --
 | |
| #  Sync_m, Synchronizer_m
 | |
| #  Usage:
 | |
| #   obj.extend(Sync_m)
 | |
| #   or
 | |
| #   class Foo
 | |
| #	include Sync_m
 | |
| #	:
 | |
| #   end
 | |
| #
 | |
| #   Sync_m#sync_mode
 | |
| #   Sync_m#sync_locked?, locked?
 | |
| #   Sync_m#sync_shared?, shared?
 | |
| #   Sync_m#sync_exclusive?, sync_exclusive?
 | |
| #   Sync_m#sync_try_lock, try_lock
 | |
| #   Sync_m#sync_lock, lock
 | |
| #   Sync_m#sync_unlock, unlock
 | |
| #
 | |
| #   Sync, Synchronicer:
 | |
| #	include Sync_m
 | |
| #   Usage:
 | |
| #   sync = Sync.new
 | |
| #
 | |
| #   Sync#mode
 | |
| #   Sync#locked?
 | |
| #   Sync#shared?
 | |
| #   Sync#exclusive?
 | |
| #   Sync#try_lock(mode) -- mode = :EX, :SH, :UN
 | |
| #   Sync#lock(mode)     -- mode = :EX, :SH, :UN
 | |
| #   Sync#unlock
 | |
| #   Sync#synchronize(mode) {...}
 | |
| #   
 | |
| #
 | |
| 
 | |
| unless defined? Thread
 | |
|   fail "Thread not available for this ruby interpreter"
 | |
| end
 | |
| 
 | |
| module Sync_m
 | |
|   RCS_ID='-$Header$-'
 | |
|   
 | |
|   # lock mode
 | |
|   UN = :UN
 | |
|   SH = :SH
 | |
|   EX = :EX
 | |
|   
 | |
|   # exceptions
 | |
|   class Err < StandardError
 | |
|     def Err.Fail(*opt)
 | |
|       fail self, sprintf(self::Message, *opt)
 | |
|     end
 | |
|     
 | |
|     class UnknownLocker < Err
 | |
|       Message = "Thread(%s) not locked."
 | |
|       def UnknownLocker.Fail(th)
 | |
| 	super(th.inspect)
 | |
|       end
 | |
|     end
 | |
|     
 | |
|     class LockModeFailer < Err
 | |
|       Message = "Unknown lock mode(%s)"
 | |
|       def LockModeFailer.Fail(mode)
 | |
| 	if mode.id2name
 | |
| 	  mode = id2name
 | |
| 	end
 | |
| 	super(mode)
 | |
|       end
 | |
|     end
 | |
|   end
 | |
|   
 | |
|   def Sync_m.define_aliases(cl)
 | |
|     cl.module_eval %q{
 | |
|       alias locked? sync_locked?
 | |
|       alias shared? sync_shared?
 | |
|       alias exclusive? sync_exclusive?
 | |
|       alias lock sync_lock
 | |
|       alias unlock sync_unlock
 | |
|       alias try_lock sync_try_lock
 | |
|       alias synchronize sync_synchronize
 | |
|     }
 | |
|   end
 | |
|   
 | |
|   def Sync_m.append_features(cl)
 | |
|     super
 | |
|     unless cl.instance_of?(Module)
 | |
|       # do nothing for Modules
 | |
|       # make aliases and include the proper module.
 | |
|       define_aliases(cl)
 | |
|     end
 | |
|   end
 | |
|   
 | |
|   def Sync_m.extend_object(obj)
 | |
|     super
 | |
|     obj.sync_extended
 | |
|   end
 | |
| 
 | |
|   def sync_extended
 | |
|     unless (defined? locked? and
 | |
| 	    defined? shared? and
 | |
| 	    defined? exclusive? and
 | |
| 	    defined? lock and
 | |
| 	    defined? unlock and
 | |
| 	    defined? try_lock and
 | |
| 	    defined? synchronize)
 | |
|       Sync_m.define_aliases(class<<self;self;end)
 | |
|     end
 | |
|     sync_initialize
 | |
|   end
 | |
| 
 | |
|   # accessing
 | |
|   def sync_locked?
 | |
|     sync_mode != UN
 | |
|   end
 | |
|   
 | |
|   def sync_shared?
 | |
|     sync_mode == SH
 | |
|   end
 | |
|   
 | |
|   def sync_exclusive?
 | |
|     sync_mode == EX
 | |
|   end
 | |
|   
 | |
|   # locking methods.
 | |
|   def sync_try_lock(mode = EX)
 | |
|     return unlock if sync_mode == UN
 | |
|     
 | |
|     Thread.critical = true
 | |
|     ret = sync_try_lock_sub(sync_mode)
 | |
|     Thread.critical = false
 | |
|     ret
 | |
|   end
 | |
|   
 | |
|   def sync_lock(m = EX)
 | |
|     return unlock if m == UN
 | |
| 
 | |
|     until (Thread.critical = true; sync_try_lock_sub(m))
 | |
|       if sync_sh_locker[Thread.current]
 | |
| 	sync_upgrade_waiting.push [Thread.current, sync_sh_locker[Thread.current]]
 | |
| 	sync_sh_locker.delete(Thread.current)
 | |
|       else
 | |
| 	sync_waiting.push Thread.current
 | |
|       end
 | |
|       Thread.stop
 | |
|     end
 | |
|     Thread.critical = false
 | |
|     self
 | |
|   end
 | |
|   
 | |
|   def sync_unlock(m = EX)
 | |
|     Thread.critical = true
 | |
|     if sync_mode == UN
 | |
|       Thread.critical = false
 | |
|       Err::UnknownLocker.Fail(Thread.current)
 | |
|     end
 | |
|     
 | |
|     m = sync_mode if m == EX and sync_mode == SH
 | |
|     
 | |
|     runnable = false
 | |
|     case m
 | |
|     when UN
 | |
|       Thread.critical = false
 | |
|       Err::UnknownLocker.Fail(Thread.current)
 | |
|       
 | |
|     when EX
 | |
|       if sync_ex_locker == Thread.current
 | |
| 	if (self.sync_ex_count = sync_ex_count - 1) == 0
 | |
| 	  self.sync_ex_locker = nil
 | |
| 	  if sync_sh_locker.include?(Thread.current)
 | |
| 	    self.sync_mode = SH
 | |
| 	  else
 | |
| 	    self.sync_mode = UN
 | |
| 	  end
 | |
| 	  runnable = true
 | |
| 	end
 | |
|       else
 | |
| 	Err::UnknownLocker.Fail(Thread.current)
 | |
|       end
 | |
|       
 | |
|     when SH
 | |
|       if (count = sync_sh_locker[Thread.current]).nil?
 | |
| 	Err::UnknownLocker.Fail(Thread.current)
 | |
|       else
 | |
| 	if (sync_sh_locker[Thread.current] = count - 1) == 0 
 | |
| 	  sync_sh_locker.delete(Thread.current)
 | |
| 	  if sync_sh_locker.empty? and sync_ex_count == 0
 | |
| 	    self.sync_mode = UN
 | |
| 	    runnable = true
 | |
| 	  end
 | |
| 	end
 | |
|       end
 | |
|     end
 | |
|     
 | |
|     if runnable
 | |
|       if sync_upgrade_waiting.size > 0
 | |
| 	for k, v in sync_upgrade_waiting
 | |
| 	  sync_sh_locker[k] = v
 | |
| 	end
 | |
| 	wait = sync_upgrade_waiting
 | |
| 	self.sync_upgrade_waiting = []
 | |
| 	Thread.critical = false
 | |
| 	
 | |
| 	for w, v in wait
 | |
| 	  w.run
 | |
| 	end
 | |
|       else
 | |
| 	wait = sync_waiting
 | |
| 	self.sync_waiting = []
 | |
| 	Thread.critical = false
 | |
| 	for w in wait
 | |
| 	  w.run
 | |
| 	end
 | |
|       end
 | |
|     end
 | |
|     
 | |
|     Thread.critical = false
 | |
|     self
 | |
|   end
 | |
|   
 | |
|   def sync_synchronize(mode = EX)
 | |
|     begin
 | |
|       sync_lock(mode)
 | |
|       yield
 | |
|     ensure
 | |
|       sync_unlock
 | |
|     end
 | |
|   end
 | |
| 
 | |
|   attr :sync_mode, true
 | |
|     
 | |
|   attr :sync_waiting, true
 | |
|   attr :sync_upgrade_waiting, true
 | |
|   attr :sync_sh_locker, true
 | |
|   attr :sync_ex_locker, true
 | |
|   attr :sync_ex_count, true
 | |
|     
 | |
|   private
 | |
| 
 | |
|   def sync_initialize
 | |
|     @sync_mode = UN
 | |
|     @sync_waiting = []
 | |
|     @sync_upgrade_waiting = []
 | |
|     @sync_sh_locker = Hash.new
 | |
|     @sync_ex_locker = nil
 | |
|     @sync_ex_count = 0
 | |
|   end
 | |
| 
 | |
|   def initialize(*args)
 | |
|     sync_initialize
 | |
|     super
 | |
|   end
 | |
|     
 | |
|   def sync_try_lock_sub(m)
 | |
|     case m
 | |
|     when SH
 | |
|       case sync_mode
 | |
|       when UN
 | |
| 	self.sync_mode = m
 | |
| 	sync_sh_locker[Thread.current] = 1
 | |
| 	ret = true
 | |
|       when SH
 | |
| 	count = 0 unless count = sync_sh_locker[Thread.current]
 | |
| 	sync_sh_locker[Thread.current] = count + 1
 | |
| 	ret = true
 | |
|       when EX
 | |
| 	# in EX mode, lock will upgrade to EX lock
 | |
| 	if sync_ex_locker == Thread.current
 | |
| 	  self.sync_ex_count = sync_ex_count + 1
 | |
| 	  ret = true
 | |
| 	else
 | |
| 	  ret = false
 | |
| 	end
 | |
|       end
 | |
|     when EX
 | |
|       if sync_mode == UN or
 | |
| 	sync_mode == SH && sync_sh_locker.size == 1 && sync_sh_locker.include?(Thread.current) 
 | |
| 	self.sync_mode = m
 | |
| 	self.sync_ex_locker = Thread.current
 | |
| 	self.sync_ex_count = 1
 | |
| 	ret = true
 | |
|       elsif sync_mode == EX && sync_ex_locker == Thread.current
 | |
| 	self.sync_ex_count = sync_ex_count + 1
 | |
| 	ret = true
 | |
|       else
 | |
| 	ret = false
 | |
|       end
 | |
|     else
 | |
|       Thread.critical = false
 | |
|       Err::LockModeFailer.Fail mode
 | |
|     end
 | |
|     return ret
 | |
|   end
 | |
| end
 | |
| Synchronizer_m = Sync_m
 | |
| 
 | |
| class Sync
 | |
|   #Sync_m.extend_class self
 | |
|   include Sync_m
 | |
|     
 | |
|   def initialize
 | |
|     super
 | |
|   end
 | |
|     
 | |
| end
 | |
| Synchronizer = Sync
 |