Class: Concurrent::Tuple
- Includes:
- Enumerable
- Defined in:
- lib/rubypitaya/app-template/vendor/bundle/ruby/3.1.0/gems/concurrent-ruby-1.1.10/lib/concurrent-ruby/concurrent/tuple.rb
Overview
A fixed size array with volatile (synchronized, thread safe) getters/setters. Mixes in Ruby’s ‘Enumerable` module for enhanced search, sort, and traversal.
Instance Attribute Summary collapse
-
#size ⇒ Object
readonly
The (fixed) size of the tuple.
Instance Method Summary collapse
-
#compare_and_set(i, old_value, new_value) ⇒ Boolean
(also: #cas)
Set the value at the given index to the new value if and only if the current value matches the given old value.
-
#each {|ref| ... } ⇒ Object
Calls the given block once for each element in self, passing that element as a parameter.
-
#get(i) ⇒ Object
(also: #volatile_get)
Get the value of the element at the given index.
-
#initialize(size) ⇒ Tuple
constructor
Create a new tuple of the given size.
-
#set(i, value) ⇒ Object
(also: #volatile_set)
Set the element at the given index to the given value.
Methods included from Enumerable
#as_json, #compact_blank, #exclude?, #excluding, #in_order_of, #including, #index_by, #index_with, #many?, #maximum, #minimum, #pick, #pluck, #sole, #sum
Constructor Details
#initialize(size) ⇒ Tuple
Create a new tuple of the given size.
33 34 35 36 37 38 39 40 41 |
# File 'lib/rubypitaya/app-template/vendor/bundle/ruby/3.1.0/gems/concurrent-ruby-1.1.10/lib/concurrent-ruby/concurrent/tuple.rb', line 33 def initialize(size) @size = size @tuple = tuple = Tuple.new(size) i = 0 while i < size tuple[i] = Concurrent::AtomicReference.new i += 1 end end |
Instance Attribute Details
#size ⇒ Object (readonly)
The (fixed) size of the tuple.
24 25 26 |
# File 'lib/rubypitaya/app-template/vendor/bundle/ruby/3.1.0/gems/concurrent-ruby-1.1.10/lib/concurrent-ruby/concurrent/tuple.rb', line 24 def size @size end |
Instance Method Details
#compare_and_set(i, old_value, new_value) ⇒ Boolean Also known as: cas
Set the value at the given index to the new value if and only if the current value matches the given old value.
73 74 75 76 |
# File 'lib/rubypitaya/app-template/vendor/bundle/ruby/3.1.0/gems/concurrent-ruby-1.1.10/lib/concurrent-ruby/concurrent/tuple.rb', line 73 def compare_and_set(i, old_value, new_value) return false if i >= @size || i < 0 @tuple[i].compare_and_set(old_value, new_value) end |
#each {|ref| ... } ⇒ Object
Calls the given block once for each element in self, passing that element as a parameter.
82 83 84 |
# File 'lib/rubypitaya/app-template/vendor/bundle/ruby/3.1.0/gems/concurrent-ruby-1.1.10/lib/concurrent-ruby/concurrent/tuple.rb', line 82 def each @tuple.each {|ref| yield ref.get} end |
#get(i) ⇒ Object Also known as: volatile_get
Get the value of the element at the given index.
47 48 49 50 |
# File 'lib/rubypitaya/app-template/vendor/bundle/ruby/3.1.0/gems/concurrent-ruby-1.1.10/lib/concurrent-ruby/concurrent/tuple.rb', line 47 def get(i) return nil if i >= @size || i < 0 @tuple[i].get end |
#set(i, value) ⇒ Object Also known as: volatile_set
Set the element at the given index to the given value
59 60 61 62 |
# File 'lib/rubypitaya/app-template/vendor/bundle/ruby/3.1.0/gems/concurrent-ruby-1.1.10/lib/concurrent-ruby/concurrent/tuple.rb', line 59 def set(i, value) return nil if i >= @size || i < 0 @tuple[i].set(value) end |