make sure sentinel values are ::Objects

Author: pitr-ch

lib/concurrent/actor/behaviour.rb

@@ -49,7 +49,7 @@ module Actor
     # -   {RestartingContext} uses
     #     {include:Actor::Behaviour.restarting_behaviour_definition}
     module Behaviour
-      MESSAGE_PROCESSED = Object.new
+      MESSAGE_PROCESSED = ::Object.new
 
       require 'concurrent/actor/behaviour/abstract'
       require 'concurrent/actor/behaviour/awaits'

lib/concurrent/agent.rb

@@ -147,7 +147,7 @@ class Agent < Synchronization::LockableObject
     ERROR_MODES = [:continue, :fail].freeze
     private_constant :ERROR_MODES
 
-    AWAIT_FLAG = Object.new
+    AWAIT_FLAG = ::Object.new
     private_constant :AWAIT_FLAG
 
     AWAIT_ACTION = ->(value, latch) { latch.count_down; AWAIT_FLAG }

lib/concurrent/constants.rb

@@ -3,6 +3,6 @@ module Concurrent
   # Various classes within allows for +nil+ values to be stored,
   # so a special +NULL+ token is required to indicate the "nil-ness".
   # @!visibility private
-  NULL = Object.new
+  NULL = ::Object.new
 
 end

lib/concurrent/edge/promises.rb

@@ -1987,7 +1987,7 @@ class Channel < Concurrent::Synchronization::Object
       safe_initialization!
 
       # Default size of the Channel, makes it accept unlimited number of messages.
-      UNLIMITED = Object.new
+      UNLIMITED = ::Object.new
       UNLIMITED.singleton_class.class_eval do
         include Comparable
 

lib/concurrent/exchanger.rb

@@ -41,7 +41,7 @@ module Concurrent
   class AbstractExchanger < Synchronization::Object
 
     # @!visibility private
-    CANCEL = Object.new
+    CANCEL = ::Object.new
     private_constant :CANCEL
 
     # @!macro [attach] exchanger_method_initialize

lib/concurrent/maybe.rb

@@ -108,7 +108,7 @@ class Maybe < Synchronization::Object
     # Indicates that the given attribute has not been set.
     # When `Just` the {#nothing} getter will return `NONE`.
     # When `Nothing` the {#just} getter will return `NONE`.
-    NONE = Object.new.freeze
+    NONE = ::Object.new.freeze
 
     # The value of a `Maybe` when `Just`. Will be `NONE` when `Nothing`.
     attr_reader :just

lib/concurrent/mvar.rb

@@ -40,11 +40,11 @@ class MVar < Synchronization::Object
     safe_initialization!
 
     # Unique value that represents that an `MVar` was empty
-    EMPTY = Object.new
+    EMPTY = ::Object.new
 
     # Unique value that represents that an `MVar` timed out before it was able
     # to produce a value.
-    TIMEOUT = Object.new
+    TIMEOUT = ::Object.new
 
     # Create a new `MVar`, either empty or with an initial value.
     #

lib/concurrent/tvar.rb

@@ -162,7 +162,7 @@ def leave_transaction
 
   class Transaction
 
-    ABORTED = Object.new
+    ABORTED = ::Object.new
 
     ReadLogEntry = Struct.new(:tvar, :version)
 

spec/concurrent/future_spec.rb

@@ -380,7 +380,7 @@ def get_ivar_from_args(opts)
       context 'deadlock avoidance' do
 
         def reentrant_observer(future)
-          obs = Object.new
+          obs = ::Object.new
           obs.define_singleton_method(:update) do |time, value, reason|
             @value = future.value
           end

spec/concurrent/ivar_spec.rb

@@ -110,7 +110,7 @@ def trigger_observable(observable)
       context 'deadlock avoidance' do
 
         def reentrant_observer(i)
-          obs = Object.new
+          obs = ::Object.new
           obs.define_singleton_method(:update) do |time, value, reason|
             @value = i.value
           end