Gecko [ lorencats.com ]

Name	Size	Permission
adder.rb	2.17 KB	-rw-r--r--
atomic_reference.rb	1.18 KB	-rw-r--r--
cheap_lockable.rb	3.07 KB	-rw-r--r--
power_of_two_tuple.rb	610 B	-rw-r--r--
striped64.rb	8.83 KB	-rw-r--r--
volatile.rb	2.04 KB	-rw-r--r--
volatile_tuple.rb	1 KB	-rw-r--r--
xor_shift_random.rb	1.4 KB	-rw-r--r--

Name

Size

Permission

Action

adder.rb

2.17 KB

-rw-r--r--

atomic_reference.rb

1.18 KB

-rw-r--r--

cheap_lockable.rb

3.07 KB

-rw-r--r--

power_of_two_tuple.rb

610 B

-rw-r--r--

striped64.rb

8.83 KB

-rw-r--r--

volatile.rb

2.04 KB

-rw-r--r--

volatile_tuple.rb

1 KB

-rw-r--r--

xor_shift_random.rb

1.4 KB

-rw-r--r--

Code Editor : volatile_tuple.rb

module ThreadSafe
  module Util
    # A fixed size array with volatile volatile getters/setters.
    # Usage:
    #   arr = VolatileTuple.new(16)
    #   arr.volatile_set(0, :foo)
    #   arr.volatile_get(0)    # => :foo
    #   arr.cas(0, :foo, :bar) # => true
    #   arr.volatile_get(0)    # => :bar
    class VolatileTuple
      include Enumerable

Tuple = defined?(Rubinius::Tuple) ? Rubinius::Tuple : Array

def initialize(size)
        @tuple = tuple = Tuple.new(size)
        i = 0
        while i < size
          tuple[i] = AtomicReference.new
          i += 1
        end
      end

def volatile_get(i)
        @tuple[i].get
      end

def volatile_set(i, value)
        @tuple[i].set(value)
      end

def compare_and_set(i, old_value, new_value)
        @tuple[i].compare_and_set(old_value, new_value)
      end
      alias_method :cas, :compare_and_set

def size
        @tuple.size
      end

def each
        @tuple.each {|ref| yield ref.get}
      end
    end
  end
end

${this.title}

Code Editor : volatile_tuple.rb