Class: FiberMon::RBFiberMon::ConditionVariable

Inherits:

Object

• Object
• FiberMon::RBFiberMon::ConditionVariable

Defined in:

lib/fiber-mon.rb

Instance Method Summary

• #broadcast(&block) ⇒ Object
• #initialize(monitor) ⇒ ConditionVariable constructor

  A new instance of ConditionVariable.

• #signal(&block) ⇒ Object
• #synchronize(&block) ⇒ Object
• #wait ⇒ Object
• #wait_until(&cond) ⇒ Object
• #wait_while(&cond) ⇒ Object

Constructor Details

#initialize(monitor) ⇒ ConditionVariable

Returns a new instance of ConditionVariable.

# File 'lib/fiber-mon.rb', line 201

def initialize(monitor)
	@mon = monitor

	@waitings = []
	@waitings_mx = Mutex.new
end

Instance Method Details

#broadcast(&block) ⇒ Object

# File 'lib/fiber-mon.rb', line 224

def broadcast(&block)
	@waitings_mx.synchronize do
	  if block_given?
	    yield
	  end

	  return if @waitings.empty?
	  fbs, @waitings = @waitings, []
	  @mon.entry_wait_resume(*fbs)
	end
end

#signal(&block) ⇒ Object

# File 'lib/fiber-mon.rb', line 212

def signal(&block)
	@waitings_mx.synchronize do
	  if block_given?
	    yield
	  end

	  if fb =  @waitings.shift
	    @mon.entry_wait_resume(fb)
	  end
	end
end

#synchronize(&block) ⇒ Object

# File 'lib/fiber-mon.rb', line 208

def synchronize(&block)
	@waitings_mx.synchronize(&block)
end

#wait ⇒ Object

# File 'lib/fiber-mon.rb', line 236

def wait
	@waitings_mx.synchronize do
	  @waitings.push @mon.current
	end
	@mon.fiber_yield
end

#wait_until(&cond) ⇒ Object

# File 'lib/fiber-mon.rb', line 243

def wait_until(&cond)
	until cond.call
	  wait
	end 
end

#wait_while(&cond) ⇒ Object

# File 'lib/fiber-mon.rb', line 249

def wait_while(&cond)
	while cond.call
	  wait
	end 
end