Sha256: 699c3c07a173c6fb37bb33cca31adf88dd9b354b966a10bf344ac521b1ba257c

Contents?: true

Size: 1.91 KB

Versions: 23

Compression:

Stored size: 1.91 KB

Contents

require "active_support/core_ext/module/delegation"

module ActiveSupport
  # NOTE: This approach has been deprecated for end-user code in favor of {thread_mattr_accessor}[rdoc-ref:Module#thread_mattr_accessor] and friends.
  # Please use that approach instead.
  #
  # This module is used to encapsulate access to thread local variables.
  #
  # Instead of polluting the thread locals namespace:
  #
  #   Thread.current[:connection_handler]
  #
  # you define a class that extends this module:
  #
  #   module ActiveRecord
  #     class RuntimeRegistry
  #       extend ActiveSupport::PerThreadRegistry
  #
  #       attr_accessor :connection_handler
  #     end
  #   end
  #
  # and invoke the declared instance accessors as class methods. So
  #
  #   ActiveRecord::RuntimeRegistry.connection_handler = connection_handler
  #
  # sets a connection handler local to the current thread, and
  #
  #   ActiveRecord::RuntimeRegistry.connection_handler
  #
  # returns a connection handler local to the current thread.
  #
  # This feature is accomplished by instantiating the class and storing the
  # instance as a thread local keyed by the class name. In the example above
  # a key "ActiveRecord::RuntimeRegistry" is stored in <tt>Thread.current</tt>.
  # The class methods proxy to said thread local instance.
  #
  # If the class has an initializer, it must accept no arguments.
  module PerThreadRegistry
    def self.extended(object)
      object.instance_variable_set "@per_thread_registry_key", object.name.freeze
    end

    def instance
      Thread.current[@per_thread_registry_key] ||= new
    end

    private
      def method_missing(name, *args, &block)
        # Caches the method definition as a singleton method of the receiver.
        #
        # By letting #delegate handle it, we avoid an enclosure that'll capture args.
        singleton_class.delegate name, to: :instance

        send(name, *args, &block)
      end
  end
end

Version data entries

23 entries across 23 versions & 3 rubygems

Version Path
activesupport-5.1.7 lib/active_support/per_thread_registry.rb
activesupport-5.1.7.rc1 lib/active_support/per_thread_registry.rb
activesupport-5.1.6.2 lib/active_support/per_thread_registry.rb
activesupport-5.1.6.1 lib/active_support/per_thread_registry.rb
activesupport-5.1.6 lib/active_support/per_thread_registry.rb
tdiary-5.0.8 vendor/bundle/gems/activesupport-5.1.5/lib/active_support/per_thread_registry.rb
activesupport-5.1.5 lib/active_support/per_thread_registry.rb
activesupport-5.1.5.rc1 lib/active_support/per_thread_registry.rb
pract6-0.1.0 .gem/ruby/2.3.0/gems/activesupport-5.1.4/lib/active_support/per_thread_registry.rb
activesupport-5.1.4 lib/active_support/per_thread_registry.rb
activesupport-5.1.4.rc1 lib/active_support/per_thread_registry.rb
activesupport-5.1.3 lib/active_support/per_thread_registry.rb
activesupport-5.1.3.rc3 lib/active_support/per_thread_registry.rb
activesupport-5.1.3.rc2 lib/active_support/per_thread_registry.rb
activesupport-5.1.3.rc1 lib/active_support/per_thread_registry.rb
tdiary-5.0.5 vendor/bundle/gems/activesupport-5.1.2/lib/active_support/per_thread_registry.rb
activesupport-5.1.2 lib/active_support/per_thread_registry.rb
activesupport-5.1.2.rc1 lib/active_support/per_thread_registry.rb
activesupport-5.1.1 lib/active_support/per_thread_registry.rb
activesupport-5.1.0 lib/active_support/per_thread_registry.rb