Module: Synctest::Patches::ConditionVariablePatch

Defined in:

lib/synctest/patches.rb

Instance Method Summary

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

Instance Method Details

#broadcast ⇒ Object

# File 'lib/synctest/patches.rb', line 290

def broadcast
  bubble = Synctest.bubble_for_operation(self)
  return super unless bubble

  bubble.condition_signal(self, broadcast: true)
end

#initialize ⇒ Object

# File 'lib/synctest/patches.rb', line 268

def initialize(...)
  super
  Synctest.associate(self)
end

#signal ⇒ Object

# File 'lib/synctest/patches.rb', line 283

def signal
  bubble = Synctest.bubble_for_operation(self)
  return super unless bubble

  bubble.condition_signal(self, broadcast: false)
end

#wait(mutex, timeout = nil) ⇒ Object

# File 'lib/synctest/patches.rb', line 273

def wait(mutex, timeout = nil)
  bubble = Synctest.bubble_for_operation(self)
  return super unless bubble
  unless Synctest.bubble_for(mutex).equal?(bubble)
    raise IsolationError, "a bubbled ConditionVariable requires a Mutex from the same bubble"
  end

  bubble.condition_wait(self, mutex, timeout)
end