Class: LightIO::Library::Thread::ConditionVariable

Inherits:

Object

• Object
• LightIO::Library::Thread::ConditionVariable

Extended by:

Base::MockMethods

Defined in:

lib/lightio/library/thread.rb

Instance Method Summary

• #broadcast ⇒ Object
• #initialize ⇒ ConditionVariable constructor

  A new instance of ConditionVariable.

• #signal ⇒ Object
• #wait(mutex, timeout = nil) ⇒ Object

Constructor Details

#initialize ⇒ ConditionVariable

Returns a new instance of ConditionVariable.

# File 'lib/lightio/library/thread.rb', line 291

def initialize
  @queue = LightIO::Library::Queue.new
end

Instance Method Details

#broadcast ⇒ Object

# File 'lib/lightio/library/thread.rb', line 296

def broadcast
  signal until @queue.num_waiting == 0
  self
end

#signal ⇒ Object

# File 'lib/lightio/library/thread.rb', line 301

def signal
  @queue << true unless @queue.num_waiting == 0
  self
end

#wait(mutex, timeout = nil) ⇒ Object

# File 'lib/lightio/library/thread.rb', line 306

def wait(mutex, timeout=nil)
  mutex.unlock
  begin
    LightIO::Library::Timeout.timeout(timeout) do
      @queue.pop
    end
  rescue Timeout::Error
    nil
  end
  mutex.lock
  self
end