123456789_123456789_123456789_123456789_123456789_

Class: Concurrent::Promises::AnyResolvedEventPromise

Constant Summary

InternalStates - Included

PENDING, RESERVED, RESOLVED

Class Attribute Summary

Class Method Summary

BlockedPromise - Inherited

AbstractPromise - Inherited

Synchronization::Object - Inherited

.atomic_attribute?, .atomic_attributes,
.attr_atomic

Creates methods for reading and writing to a instance variable with volatile (Java) semantic as .attr_volatile does.

.attr_volatile

Creates methods for reading and writing (as attr_accessor does) to a instance variable with volatile (Java) semantic.

.ensure_safe_initialization_when_final_fields_are_present

For testing purposes, quite slow.

.new

Has to be called by children.

.safe_initialization!, .define_initialize_atomic_fields

Synchronization::AbstractObject - Inherited

Instance Method Summary

Constructor Details

.new(delayed, blockers_count, default_executor) ⇒ AnyResolvedEventPromise (private)

[ GitHub ]

  
# File 'lib/concurrent-ruby/concurrent/promises.rb', line 2054

def initialize(delayed, blockers_count, default_executor)
  super delayed, blockers_count, Event.new(self, default_executor)
end

Instance Method Details

#on_resolvable(resolved_future, index) (private)

[ GitHub ]

  
# File 'lib/concurrent-ruby/concurrent/promises.rb', line 2062

def on_resolvable(resolved_future, index)
  resolve_with RESOLVED, false
end

#resolvable?(countdown, future, index) ⇒ Boolean (private)

[ GitHub ]

  
# File 'lib/concurrent-ruby/concurrent/promises.rb', line 2058

def resolvable?(countdown, future, index)
  true
end