mirror of
https://github.com/rails/rails.git
synced 2022-11-09 12:12:34 -05:00
36 lines
653 B
Ruby
36 lines
653 B
Ruby
|
require 'active_support/concurrency/share_lock'
|
||
|
|
||
|
module ActiveSupport
|
||
|
module Dependencies #:nodoc:
|
||
|
class Interlock
|
||
|
def initialize
|
||
|
@lock = ActiveSupport::Concurrency::ShareLock.new(true)
|
||
|
end
|
||
|
|
||
|
def loading
|
||
|
@lock.exclusive do
|
||
|
yield
|
||
|
end
|
||
|
end
|
||
|
|
||
|
def start_running
|
||
|
@lock.start_sharing
|
||
|
end
|
||
|
|
||
|
def done_running
|
||
|
@lock.stop_sharing
|
||
|
end
|
||
|
|
||
|
def running
|
||
|
@lock.sharing do
|
||
|
yield
|
||
|
end
|
||
|
end
|
||
|
|
||
|
# Match the Mutex API, so we can be used by Rack::Lock
|
||
|
alias :lock :start_running
|
||
|
alias :unlock :done_running
|
||
|
end
|
||
|
end
|
||
|
end
|