2007-08-24 15:26:28 +00:00
|
|
|
class Mutex
|
2010-03-29 12:48:43 +00:00
|
|
|
# call-seq:
|
|
|
|
# mutex.synchronize { ... }
|
|
|
|
#
|
|
|
|
# Obtains a lock, runs the block, and releases the lock when the
|
|
|
|
# block completes. See the example under Mutex.
|
2007-08-24 18:10:37 +00:00
|
|
|
def synchronize
|
|
|
|
self.lock
|
2007-08-27 16:48:14 +00:00
|
|
|
begin
|
|
|
|
yield
|
|
|
|
ensure
|
2008-01-10 09:01:30 +00:00
|
|
|
self.unlock rescue nil
|
2007-08-27 16:48:14 +00:00
|
|
|
end
|
2007-08-24 15:26:28 +00:00
|
|
|
end
|
|
|
|
end
|
|
|
|
|
2007-08-25 01:09:08 +00:00
|
|
|
class Thread
|
2010-04-10 22:09:09 +00:00
|
|
|
MUTEX_FOR_THREAD_EXCLUSIVE = Mutex.new # :nodoc:
|
2010-03-29 12:48:43 +00:00
|
|
|
|
|
|
|
# call-seq:
|
|
|
|
# Thread.exclusive { block } => obj
|
2011-05-15 11:55:52 +00:00
|
|
|
#
|
2010-03-29 12:48:43 +00:00
|
|
|
# Wraps a block in Thread.critical, restoring the original value
|
|
|
|
# upon exit from the critical section, and returns the value of the
|
|
|
|
# block.
|
2007-08-25 01:09:08 +00:00
|
|
|
def self.exclusive
|
|
|
|
MUTEX_FOR_THREAD_EXCLUSIVE.synchronize{
|
|
|
|
yield
|
|
|
|
}
|
|
|
|
end
|
|
|
|
end
|