Method: Concurrent::IVar#set

Defined in:

lib/concurrent/ivar.rb

#set(value = NULL) { ... } ⇒ IVar

Set the ‘IVar` to a value and wake or notify all threads waiting on it.

Parameters:

• value (Object) (defaults to: NULL) —

  the value to store in the ‘IVar`

Yields:

• A block operation to use for setting the value

Returns:

• (IVar) —

  self

Raises:

• (ArgumentError) —

  if both a value and a block are given

• (Concurrent::MultipleAssignmentError) —

  if the ‘IVar` has already been set or otherwise completed

# File 'lib/concurrent/ivar.rb', line 112

def set(value = NULL)
  check_for_block_or_value!(block_given?, value)
  raise MultipleAssignmentError unless compare_and_set_state(:processing, :pending)

  begin
    value = yield if block_given?
    complete_without_notification(true, value, nil)
  rescue => ex
    complete_without_notification(false, nil, ex)
  end

  notify_observers(self.value, reason)
  self
end