Contents

require 'spec_helper'
require 'rom/memory/storage'

describe ROM::Memory::Storage do
  describe 'thread safe' do
    let(:threads) { 4 }
    let(:operations) { 5000 }

    describe 'data' do
      it 'create datasets properly' do
        storage = ROM::Memory::Storage.new

        threaded_operations do |thread, operation|
          key = "#{thread}:#{operation}"
          storage.create_dataset(key)
        end

        expect(storage.size).to eql(threads * operations)
      end
    end

    describe 'dataset' do
      it 'inserts data in proper order' do
        storage = ROM::Memory::Storage.new
        dataset = storage.create_dataset(:ary)

        threaded_operations do
          dataset << :data
        end

        expect(dataset.size).to eql(threads * operations)
      end
    end

    def threaded_operations
      threads.times.map do |thread|
        Thread.new do
          operations.times do |operation|
            yield thread, operation
          end
        end
      end.each(&:join)
    end
  end
end

Version data entries

7 entries across 7 versions & 1 rubygems

Version	Path
rom-0.6.2	spec/unit/rom/memory/storage_spec.rb
rom-0.6.1	spec/unit/rom/memory/storage_spec.rb
rom-0.6.0	spec/unit/rom/memory/storage_spec.rb
rom-0.6.0.rc1	spec/unit/rom/memory/storage_spec.rb
rom-0.6.0.beta3	spec/unit/rom/memory/storage_spec.rb
rom-0.6.0.beta2	spec/unit/rom/memory/storage_spec.rb
rom-0.6.0.beta1	spec/unit/rom/memory/storage_spec.rb