Sha256: 213f36587e8464dcec59e25f58a878cbf05c7b27e42a651985ad9118b3f3da75
Contents?: true
Size: 1.13 KB
Versions: 84
Compression:
Stored size: 1.13 KB
Contents
# frozen_string_literal: true
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(&block)
@lock.exclusive(purpose: :load, compatible: [:load], after_compatible: [:load], &block)
end
def unloading(&block)
@lock.exclusive(purpose: :unload, compatible: [:load, :unload], after_compatible: [:load, :unload], &block)
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(&block)
@lock.sharing(&block)
end
def permit_concurrent_loads(&block)
@lock.yield_shares(compatible: [:load], &block)
end
def raw_state(&block) # :nodoc:
@lock.raw_state(&block)
end
end
end
end
Version data entries
84 entries across 80 versions & 11 rubygems