Sha256: 76b00ccaa75c704aa51a005d52641c7216eec5094972341b442f05ff3b626974

Contents?: true

Size: 637 Bytes

Versions: 47

Compression:

Stored size: 637 Bytes

Contents

require "spec_helper"
require "bunny/concurrent/atomic_fixnum"

describe Bunny::Concurrent::AtomicFixnum do
  it "allows retrieving the current value" do
    af = described_class.new(0)

    expect(af.get).to eq 0
    expect(af).to eq 0
  end

  it "can be updated" do
    af = described_class.new(0)

    expect(af.get).to eq 0
    Thread.new do
      af.set(10)
    end
    sleep 0.6
    expect(af.get).to eq 10
  end

  it "can be incremented" do
    af = described_class.new(0)

    expect(af.get).to eq 0
    10.times do
      Thread.new do
        af.increment
      end
    end
    sleep 0.6
    expect(af.get).to eq 10
  end
end

Version data entries

47 entries across 47 versions & 1 rubygems

Version Path
bunny-2.19.0 spec/unit/concurrent/atomic_fixnum_spec.rb
bunny-2.18.0 spec/unit/concurrent/atomic_fixnum_spec.rb
bunny-2.17.0 spec/unit/concurrent/atomic_fixnum_spec.rb
bunny-2.16.1 spec/unit/concurrent/atomic_fixnum_spec.rb
bunny-2.15.0 spec/unit/concurrent/atomic_fixnum_spec.rb
bunny-2.14.4 spec/unit/concurrent/atomic_fixnum_spec.rb
bunny-2.14.3 spec/unit/concurrent/atomic_fixnum_spec.rb
bunny-2.14.2 spec/unit/concurrent/atomic_fixnum_spec.rb
bunny-2.14.1 spec/unit/concurrent/atomic_fixnum_spec.rb
bunny-2.13.0 spec/unit/concurrent/atomic_fixnum_spec.rb
bunny-2.12.1 spec/unit/concurrent/atomic_fixnum_spec.rb
bunny-2.12.0 spec/unit/concurrent/atomic_fixnum_spec.rb
bunny-2.12.0.rc1 spec/unit/concurrent/atomic_fixnum_spec.rb
bunny-2.11.0 spec/unit/concurrent/atomic_fixnum_spec.rb
bunny-2.11.0.pre1 spec/unit/concurrent/atomic_fixnum_spec.rb
bunny-2.10.0 spec/unit/concurrent/atomic_fixnum_spec.rb
bunny-2.9.2 spec/unit/concurrent/atomic_fixnum_spec.rb
bunny-2.9.1 spec/unit/concurrent/atomic_fixnum_spec.rb
bunny-2.6.7 spec/unit/concurrent/atomic_fixnum_spec.rb
bunny-2.7.4 spec/unit/concurrent/atomic_fixnum_spec.rb