Module: Concurrent::ThreadSafe::Util

# File 'lib/concurrent-ruby/concurrent/thread_safe/util/data_structures.rb', line 16

def self.make_synchronized_on_cruby(klass)
  klass.class_eval do
    def initialize(*args, &block)
      @_monitor = Monitor.new
      super
    end

    def initialize_copy(other)
      # make sure a copy is not sharing a monitor with the original object!
      @_monitor = Monitor.new
      super
    end
  end

  klass.superclass.instance_methods(false).each do |method|
    klass.class_eval <<-RUBY, __FILE__, __LINE__ + 1
      def #{method}(*args)
        monitor = @_monitor
        monitor or raise("BUG: Internal monitor was not properly initialized. Please report this to the concurrent-ruby developers.")
        monitor.synchronize { super }
      end
    RUBY
  end
end