Sha256: 796cd65d32d2ff87039889c1f41c1fc0434885ea1c53f392254162c34a9f78a2

Contents?: true

Size: 620 Bytes

Versions: 15

Compression:

Stored size: 620 Bytes

Contents

$:.unshift('lib')

require 'rufus/cloche'

workdir = File.join(File.dirname(__FILE__), '..', '..', 'tcloche')

FileUtils.rm_rf(workdir) rescue nil

C = Rufus::Cloche.new(:dir => workdir)

d = C.get('whatever', 'nada')
C.delete(d) if d

C.put({ '_id' => 'nada', 'where' => 'London', 'type' => 'whatever' })
$d = C.get('whatever', 'nada')

Thread.abort_on_exception = true

t1 = Thread.new do
  p [ Thread.current.object_id, :delete, $d['_rev'], C.delete($d) ]
end
t0 = Thread.new do
  p [ Thread.current.object_id, :put, $d['_rev'], C.put($d) ]
end

sleep 0.100

p C.get('whatever', 'nada')
p C.get('whatever', 'nada')

Version data entries

15 entries across 15 versions & 1 rubygems

Version Path
rufus-cloche-1.0.2 test/conc/put_vs_delete.rb
rufus-cloche-1.0.1 test/conc/put_vs_delete.rb
rufus-cloche-1.0.0 test/conc/put_vs_delete.rb
rufus-cloche-0.1.21 test/conc/put_vs_delete.rb
rufus-cloche-0.1.20 test/conc/put_vs_delete.rb
rufus-cloche-0.1.19 test/conc/put_vs_delete.rb
rufus-cloche-0.1.18 test/conc/put_vs_delete.rb
rufus-cloche-0.1.17 test/conc/put_vs_delete.rb
rufus-cloche-0.1.16 test/conc/put_vs_delete.rb
rufus-cloche-0.1.15 test/conc/put_vs_delete.rb
rufus-cloche-0.1.14 test/conc/put_vs_delete.rb
rufus-cloche-0.1.13 test/conc/put_vs_delete.rb
rufus-cloche-0.1.12 test/conc/put_vs_delete.rb
rufus-cloche-0.1.11 test/conc/put_vs_delete.rb
rufus-cloche-0.1.10 test/con/put_vs_delete.rb