Sha256: d5b3c4acdfc79ca4e09d1363efd692be40a4e7daac5ac0311ef4e6cd94c37cec
Contents?: true
Size: 536 Bytes
Versions: 17
Compression:
Stored size: 536 Bytes
Contents
require 'monitor'
require 'concurrent/synchronization/mutex_object'
module Concurrent
module Synchronization
# @!visibility private
# @!macro internal_implementation_note
class MonitorObject < MutexObject
def initialize
@__lock__ = ::Monitor.new
@__condition__ = @__lock__.new_cond
end
protected
def synchronize
@__lock__.synchronize { yield }
end
def ns_wait(timeout = nil)
@__condition__.wait timeout
self
end
end
end
end
Version data entries
17 entries across 15 versions & 5 rubygems