Contents

require 'active_support/concurrency/share_lock'

module ActiveSupport #:nodoc:
  module Dependencies #:nodoc:
    class Interlock
      def initialize # :nodoc:
        @lock = ActiveSupport::Concurrency::ShareLock.new
      end

      def loading
        @lock.exclusive(purpose: :load, compatible: [:load], after_compatible: [:load]) do
          yield
        end
      end

      def unloading
        @lock.exclusive(purpose: :unload, compatible: [:load, :unload], after_compatible: [:load, :unload]) do
          yield
        end
      end

      def start_unloading
        @lock.start_exclusive(purpose: :unload, compatible: [:load, :unload])
      end

      def done_unloading
        @lock.stop_exclusive(compatible: [:load, :unload])
      end

      def start_running
        @lock.start_sharing
      end

      def done_running
        @lock.stop_sharing
      end

      def running
        @lock.sharing do
          yield
        end
      end

      def permit_concurrent_loads
        @lock.yield_shares(compatible: [:load]) do
          yield
        end
      end
    end
  end
end

Version data entries

8 entries across 8 versions & 3 rubygems

Version	Path
abaci-0.3.0	vendor/bundle/gems/activesupport-5.0.0/lib/active_support/dependencies/interlock.rb
second_step-0.1.2	secondstep-notify-1.0.0-osx/lib/ruby/lib/ruby/gems/2.2.0/gems/activesupport-5.0.0.1/lib/active_support/dependencies/interlock.rb
activesupport-5.0.0.1	lib/active_support/dependencies/interlock.rb
activesupport-5.0.0	lib/active_support/dependencies/interlock.rb
activesupport-5.0.0.rc2	lib/active_support/dependencies/interlock.rb
activesupport-5.0.0.racecar1	lib/active_support/dependencies/interlock.rb
activesupport-5.0.0.rc1	lib/active_support/dependencies/interlock.rb
activesupport-5.0.0.beta4	lib/active_support/dependencies/interlock.rb