Merge pull request #498 from ruby-concurrency/truffle-compatibility

Alter backends used by Truffle

Author: chrisseaton

lib/concurrent/array.rb

@@ -25,7 +25,7 @@ class Array < ::Array
       include JRuby::Synchronized
     end
 
-  elsif Concurrent.on_rbx?
+  elsif Concurrent.on_rbx? || Concurrent.on_truffle?
     require 'monitor'
     require 'concurrent/thread_safe/util/array_hash_rbx'
 

lib/concurrent/atomic_reference/jruby+truffle.rb

@@ -1 +1 @@
-require 'concurrent/atomic_reference/rbx'
+require 'concurrent/atomic_reference/mutex_atomic'

lib/concurrent/hash.rb

@@ -22,7 +22,7 @@ class Hash < ::Hash
       include JRuby::Synchronized
     end
 
-  elsif Concurrent.on_rbx?
+  elsif Concurrent.on_rbx? || Concurrent.on_truffle?
     require 'monitor'
     require 'concurrent/thread_safe/util/array_hash_rbx'
 

lib/concurrent/map.rb

@@ -18,6 +18,9 @@ module Collection
                           when 'rbx'
                             require 'concurrent/collection/map/atomic_reference_map_backend'
                             AtomicReferenceMapBackend
+                          when 'jruby+truffle'
+                            require 'concurrent/collection/map/atomic_reference_map_backend'
+                            AtomicReferenceMapBackend
                           else
                             warn 'Concurrent::Map: unsupported Ruby engine, using a fully synchronized Concurrent::Map implementation' if $VERBOSE
                             require 'concurrent/collection/map/synchronized_map_backend'

lib/concurrent/synchronization/lockable_object.rb

@@ -13,7 +13,7 @@ module Synchronization
                                    when Concurrent.on_rbx?
                                      RbxLockableObject
                                    when Concurrent.on_truffle?
-                                     TruffleLockableObject
+                                     MriMutexLockableObject
                                    else
                                      warn 'Possibly unsupported Ruby implementation'
                                      MriMonitorLockableObject

lib/concurrent/utility/processor_counter.rb

@@ -75,6 +75,8 @@ def physical_processor_count
       def compute_processor_count
         if Concurrent.on_jruby?
           java.lang.Runtime.getRuntime.availableProcessors
+        elsif Concurrent.on_truffle?
+          Truffle::Primitive.logical_processors
         else
           os_name = RbConfig::CONFIG["target_os"]
           if os_name =~ /mingw|mswin/