Exception: UnblockError

Inherits:

StandardError

• Object
• StandardError
• UnblockError

Defined in:

lib/buzzcore/extra/thread_utils.rb

Overview

class MultiThreadVariableMonitor

include MonitorMixin

class UnblockError < StandardError; end
class TimeoutError < StandardError; end
class LockFailedError < StandardError; end

def initialize(aTimeout=nil)
	mon_initialize()
	@value = nil
	@unblock = false
	@timeout = aTimeout
	@readable = new_cond
	@writable = new_cond
	@is_first_write = true
end

def value
	raise UnblockError.new if @unblock
	mon_synchronize do
		raise TimeoutError.new if not @readable.wait(@timeout)
		result = @value
		@writable.signal
	end
	return result
end

def value=(v)
	raise UnblockError.new if @unblock
	mon_synchronize do
		if @is_first_write
			@is_first_write = false
		else
			raise TimeoutError.new if not @writable.wait(@timeout)
		end
		@value = v
		@readable.signal
	end
	return v
end

def unblock()
	@unblock = true;
	@readable.broadcast
	@writable.broadcast
	while @readable.count_waiters()>0 or @writable.count_waiters()>0 do
		sleep(1)
	end
end

end