Class: Concurrent::Tuple
- Inherits:
-
Object
- Object
- Concurrent::Tuple
- Includes:
- Enumerable
- Defined in:
- 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 ⇒ undocumented
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| ... } ⇒ undocumented
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.
Constructor Details
#initialize(size) ⇒ Tuple
Create a new tuple of the given size.
33 34 35 36 37 38 39 40 41 |
# File '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 ⇒ undocumented (readonly)
The (fixed) size of the tuple.
24 25 26 |
# File '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/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| ... } ⇒ undocumented
Calls the given block once for each element in self, passing that element as a parameter.
82 83 84 |
# File '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/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/concurrent-ruby/concurrent/tuple.rb', line 59 def set(i, value) return nil if i >= @size || i < 0 @tuple[i].set(value) end |