RubyGems.org

atomic

1.1.7

An atomic reference implementation for JRuby, Rubinius, and MRI.

Changes since 1.1.6

  • fa74e58 Bump version to 1.1.7.

  • 9b58cf0 Merge pull request #20 from lazyspark/master

  • 14fc4a9 Removed compiled gem from src

  • 7d0ade6 Changing the arch to native, to make it successfully compile using mingw

Summary

This library provides:

  • an Atomic class that guarantees atomic updates to its contained value

The Atomic class provides accessors for the contained “value” plus two update methods:

  • update will run the provided block, passing the current value and replacing it with the block result iff the value has not been changed in the mean time. It may run the block repeatedly if there are other concurrent updates in progress.

  • try_update will run the provided block, passing the current value and replacing it with the block result. If the value changes before the update can happen, it will throw Atomic::ConcurrentUpdateError.

The atomic repository is at github.com/headius/ruby-atomic.

Usage

The simplest way to use “atomic” is to call the “update” or “try_update” methods.

“try_update” and “update” both call the given block, passing the current value and using the block's result as the new value. If the value is updated by another thread before the block completes, “try update” raises a ConcurrentUpdateError and “update” retries the block. Because “update” may call the block several times when multiple threads are all updating the same value, the block's logic should be kept as simple as possible.

require 'atomic'

my_atomic = Atomic.new(0)

my_atomic.update {|v| v + 1}

begin

  my_atomic.try_update {|v| v + 1}

rescue Atomic::ConcurrentUpdateError => cue

  # deal with it (retry, propagate, etc)

end

It's also possible to use the regular get/set operations on the Atomic, if you want to avoid the exception and respond to contended changes in some other way.

my_atomic = Atomic.new(0)

my_atomic.value # => 0

my_atomic.value = 1

my_atomic.swap(2) # => 1

my_atomic.compare_and_swap(2, 3) # => true, updated to 3

my_atomic.compare_and_swap(2, 3) # => false, current is not 2

Building

As of 1.1.0, JDK8 is required to build the atomic gem, since it attempts to use the new atomic Unsafe.getAndSetObject method only in JDK8. The resulting code should still work fine as far back as Java 5.

installgem install atomic -v 1.1.7
Authors

Charles Oliver Nutter, MenTaLguY, Sokolov Yura

6,247,879 total downloads 8,903 for this version
Owners

F1d37642fdaa1662ff46e4c65731e9abC203190318ed9534390c93d1744a6cf1

Gemfile
gem 'atomic', '~> 1.1.7'
Versions
  1. 1.1.16 March 17, 2014 java (22.5 KB)
  2. 1.1.16 March 17, 2014 (16.5 KB)
  3. 1.1.15 February 26, 2014 (16.5 KB)
  4. 1.1.15 February 26, 2014 java (22.5 KB)
  5. 1.1.14 September 10, 2013 java (21.5 KB)
Show all versions (53 total)