1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
|
#!/usr/bin/env ruby
#$: << File.expand_path('../../lib', __FILE__)
require 'concurrent/atomics'
require 'benchmark'
require 'rbconfig'
THREADS = 1
TESTS = 10_000_000
def atomic_test(clazz, opts = {})
threads = opts.fetch(:threads, 5)
tests = opts.fetch(:tests, 100)
atomic = clazz.new
latch = Concurrent::CountDownLatch.new(threads)
print "Testing with #{clazz}...\n"
Benchmark.bmbm do |bm|
bm.report do
threads.times do |i|
Thread.new do
tests.times{ atomic.value = true }
latch.count_down
end
end
latch.wait
end
end
end
puts "Testing with #{RbConfig::CONFIG['ruby_install_name']} #{RUBY_VERSION}"
atomic_test(Concurrent::MutexAtomicBoolean, threads: THREADS, tests: TESTS)
if defined? Concurrent::CAtomicBoolean
atomic_test(Concurrent::CAtomicBoolean, threads: THREADS, tests: TESTS)
elsif RUBY_PLATFORM == 'java'
atomic_test(Concurrent::JavaAtomicBoolean, threads: THREADS, tests: TESTS)
end
|
