# frozen_string_literal: true # @api public # @since 0.5.0 module AnyCache::Plugins require_relative 'plugins/abstract' require_relative 'plugins/registry' require_relative 'plugins/interface_access_mixin' # @since 0.5.0 @plugin_registry = Registry.new # @since 0.5.0 @access_lock = Mutex.new class << self # @param plugin_name [Symbol, String] # @return [void] # # @api public # @since 0.5.0 def load(plugin_name) thread_safe { plugin_registry[plugin_name].load! } end # @return [Array] # # @api public # @since 0.5.0 def names thread_safe { plugin_registry.names } end # @param plugin_name [Symbol, String] # @return [void] # # @api private # @since 0.5.0 def register(plugin_name, plugin_module) thread_safe { plugin_registry[plugin_name] = plugin_module } end private # @return [AnyCache::Plugins::Registry] # # @api private # @since 0.5.0 attr_reader :plugin_registry # @return [Mutex] # # @api private # @since 0.5.0 attr_reader :access_lock # @return [void] # # @api private # @since 0.5.0 def thread_safe access_lock.synchronize { yield if block_given? } end end end