class Concurrent::MVar

def initialize(value = EMPTY, opts = {})

Parameters:
  • opts (Hash) -- the options controlling how the future will be processed 
def initialize(value = EMPTY, opts = {})
  @value = value
  @mutex = Mutex.new
  @empty_condition = ConditionVariable.new
  @full_condition = ConditionVariable.new
  set_deref_options(opts)
end