Created specs to test the various gem builds.

Author: jdantonio

build-tests/atomic_boolean_builds_spec.rb

@@ -0,0 +1,84 @@
+require 'benchmark'
+require_relative 'example_group_extensions'
+require_relative 'platform_helpers'
+
+require 'concurrent/atomics'
+
+def atomic_boolean_test(clazz, opts = {})
+  threads = opts.fetch(:threads, 5)
+  tests = opts.fetch(:tests, 100)
+
+  atomic = Concurrent.const_get(clazz.to_s).new
+  latch = Concurrent::CountDownLatch.new(threads)
+
+  stats = Benchmark.measure do
+    threads.times do |i|
+      Thread.new do
+        tests.times{ atomic.value = true }
+        latch.count_down
+      end
+    end
+    latch.wait
+  end
+  stats
+end
+
+describe Concurrent::AtomicBoolean do
+
+  let!(:threads) { 10 }
+  let!(:tests) { 1000 }
+
+  describe Concurrent::MutexAtomicBoolean do
+
+    specify 'is defined' do
+      expect(defined?(Concurrent::MutexAtomicBoolean)).to be_truthy
+    end
+
+    specify 'runs the benchmarks' do
+      stats = atomic_boolean_test('MutexAtomicBoolean', threads: threads, tests: tests)
+      expect(stats).to be_benchmark_results
+    end
+  end
+
+  if jruby?
+
+    describe Concurrent::JavaAtomicBoolean do
+
+      specify 'Concurrent::JavaAtomicBoolean is defined' do
+        expect(defined?(Concurrent::JavaAtomicBoolean)).to be_truthy
+      end
+
+      specify 'runs the benchmarks' do
+        stats = atomic_boolean_test('JavaAtomicBoolean', threads: threads, tests: tests)
+        expect(stats).to be_benchmark_results
+      end
+    end
+
+  else
+
+    specify 'Concurrent::JavaAtomicBoolean is not defined' do
+      expect(defined?(Concurrent::JavaAtomicBoolean)).to be_falsey
+    end
+  end
+
+  if 'EXT' == ENV['TEST_PLATFORM']
+
+    describe Concurrent::CAtomicBoolean do
+
+      specify 'Concurrent::CAtomicBoolean is defined' do
+        expect(defined?(Concurrent::CAtomicBoolean)).to be_truthy
+      end
+
+      specify 'runs the benchmarks' do
+        stats = atomic_boolean_test('CAtomicBoolean', threads: threads, tests: tests)
+        expect(stats).to be_benchmark_results
+      end
+    end
+
+  else
+
+    specify 'Concurrent::CAtomicBoolean is not defined' do
+      expect(defined?(Concurrent::CAtomicBoolean)).to be_falsey
+    end
+  end
+end

build-tests/atomic_fixnum_builds_spec.rb

@@ -0,0 +1,84 @@
+require 'benchmark'
+require_relative 'example_group_extensions'
+require_relative 'platform_helpers'
+
+require 'concurrent/atomics'
+
+def atomic_fixnum_test(clazz, opts = {})
+  threads = opts.fetch(:threads, 5)
+  tests = opts.fetch(:tests, 100)
+
+  atomic = Concurrent.const_get(clazz.to_s).new
+  latch = Concurrent::CountDownLatch.new(threads)
+
+  stats = Benchmark.measure do
+    threads.times do |i|
+      Thread.new do
+        tests.times{ atomic.up }
+        latch.count_down
+      end
+    end
+    latch.wait
+  end
+  stats
+end
+
+describe Concurrent::AtomicFixnum do
+
+  let!(:threads) { 10 }
+  let!(:tests) { 1000 }
+
+  describe Concurrent::MutexAtomicFixnum do
+
+    specify 'is defined' do
+      expect(defined?(Concurrent::MutexAtomicFixnum)).to be_truthy
+    end
+
+    specify 'runs the benchmarks' do
+      stats = atomic_fixnum_test('MutexAtomicFixnum', threads: threads, tests: tests)
+      expect(stats).to be_benchmark_results
+    end
+  end
+
+  if jruby?
+
+    describe Concurrent::JavaAtomicFixnum do
+
+      specify 'Concurrent::JavaAtomicFixnum is defined' do
+        expect(defined?(Concurrent::JavaAtomicFixnum)).to be_truthy
+      end
+
+      specify 'runs the benchmarks' do
+        stats = atomic_fixnum_test('JavaAtomicFixnum', threads: threads, tests: tests)
+        expect(stats).to be_benchmark_results
+      end
+    end
+
+  else
+
+    specify 'Concurrent::JavaAtomicFixnum is not defined' do
+      expect(defined?(Concurrent::JavaAtomicFixnum)).to be_falsey
+    end
+  end
+
+  if 'EXT' == ENV['TEST_PLATFORM']
+
+    describe Concurrent::CAtomicFixnum do
+
+      specify 'Concurrent::CAtomicFixnum is defined' do
+        expect(defined?(Concurrent::CAtomicFixnum)).to be_truthy
+      end
+
+      specify 'runs the benchmarks' do
+        stats = atomic_fixnum_test('CAtomicFixnum', threads: threads, tests: tests)
+        expect(stats).to be_benchmark_results
+      end
+    end
+
+  else
+
+    specify 'Concurrent::CAtomicFixnum is not defined' do
+      expect(defined?(Concurrent::CAtomicFixnum)).to be_falsey
+    end
+  end
+end

build-tests/example_group_extensions.rb

@@ -0,0 +1,7 @@
+require 'benchmark'
+
+RSpec::Matchers.define :be_benchmark_results do
+  match do |actual|
+    actual.is_a? Benchmark::Tms
+  end
+end

build-tests/platform_helpers.rb

@@ -0,0 +1,13 @@
+require 'rbconfig'
+
+def mri?(engine = RUBY_ENGINE)
+  engine == 'ruby'
+end
+
+def jruby?(engine = RUBY_ENGINE)
+  engine == 'jruby'
+end
+
+def rbx?(engine = RUBY_ENGINE)
+  engine == 'rbx'
+end

build-tests/runner.rb

@@ -0,0 +1,105 @@
+#!/usr/bin/env ruby
+
+if File.exist?('Gemfile')
+  puts <<-WARNING
+!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!
+!! A Gemfile has been detected. This will likely cause some tests   !!
+!! to erroneously fail (RSpec + Bundler shenanigans!). You may need !!
+!! to run tests from a different directory.                         !!
+!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!
+  WARNING
+end
+
+$:.push File.join(File.dirname(__FILE__), '..', 'lib')
+
+require 'concurrent/version'
+require_relative 'platform_helpers'
+
+EXT_PLATFORMS = {
+  'i686-linux' => 'x86-linux',
+  'x86_64-linux' => 'x86_64-linux',
+  'x86-mingw32' => 'x86-mingw32',
+  'x64-mingw32' => 'x64-mingw32',
+  'i386-solaris2.11' => 'x86-solaris-2.11',
+  'x86_64-darwin14.0' => 'x86_64-darwin-14',
+}
+
+TEST_PATH = File.dirname(__FILE__)
+PKG_PATH = File.join(File.dirname(__FILE__), '..', 'pkg')
+
+RSPEC = "rspec --default-path #{TEST_PATH} -fd --color --seed 0"
+
+UNINSTALL_GEMS_COMMAND = <<-CMD
+gem uninstall -q -a -I concurrent-ruby-ext
+gem uninstall -q -a -I concurrent-ruby
+gem uninstall -q -a -I ref
+CMD
+
+SUITE_BREAK = "######################################################################\n"
+GEM_BREAK   = "----------------------------------------------------------------------\n"
+
+def platform_specific_extensions?(platform = RUBY_PLATFORM)
+  EXT_PLATFORMS.keys.include?(platform) &&
+    File.exists?("#{PKG_PATH}/#{extension_gem_name(platform)}")
+end
+
+def extension_gem_name(platform = RUBY_PLATFORM)
+  platform = EXT_PLATFORMS.fetch(platform, '')
+  platform = '-' + platform unless platform.empty?
+  "concurrent-ruby-ext-#{Concurrent::EXT_VERSION}#{platform}.gem"
+end
+
+def install_gems_command(ext, platform = '')
+  cmd = "gem install #{PKG_PATH}/concurrent-ruby-#{Concurrent::VERSION}.gem"
+  if ext
+    cmd << "\ngem install #{PKG_PATH}/#{extension_gem_name(platform)}"
+  end
+  cmd
+end
+
+def install_java_gem_command
+  "gem install #{PKG_PATH}/concurrent-ruby-#{Concurrent::VERSION}-java.gem"
+end
+
+def run_tests_cmd(file, ext, platform = '')
+  test_platform = if ext
+                    'EXT'
+                  elsif jruby?(platform)
+                    'JRUBY'
+                  else
+                    'RUBY'
+                  end
+
+  cmd = if jruby?(platform)
+          install_java_gem_command
+        else
+          install_gems_command(ext, platform)
+        end
+
+  cmd << "\n"
+  cmd << "TEST_PLATFORM='#{test_platform}' #{RSPEC} #{file}"
+  cmd << "\n"
+  cmd << UNINSTALL_GEMS_COMMAND
+  cmd
+end
+
+TESTS = Dir["#{TEST_PATH}/*_spec.rb"]
+ok = system(UNINSTALL_GEMS_COMMAND)
+
+TESTS.each do |file|
+  puts SUITE_BREAK
+  puts "Running #{file}"
+  puts GEM_BREAK
+  ok = system(run_tests_cmd(file, false))
+  if jruby?
+    puts GEM_BREAK
+    ok = system(run_tests_cmd(file, false, 'jruby'))
+  elsif mri?
+    puts GEM_BREAK
+    ok = system(run_tests_cmd(file, true))
+    if platform_specific_extensions?(RUBY_PLATFORM)
+      puts GEM_BREAK
+      ok = system(run_tests_cmd(file, true, RUBY_PLATFORM))
+    end
+  end
+end

spec/spec_helper.rb

@@ -8,11 +8,15 @@
 
 SimpleCov.start do
   project_name 'concurrent-ruby'
+  add_filter '/build-tests/'
   add_filter '/coverage/'
   add_filter '/doc/'
+  add_filter '/examples/'
   add_filter '/pkg/'
   add_filter '/spec/'
   add_filter '/tasks/'
+  add_filter '/yard-template/'
+  add_filter '/yardoc/'
 end
 
 require 'concurrent'