Sha256: 2a7835f319b0eccce6f125074336005898aba6f0ac30bbf1faf72f5f99d4d712
Contents?: true
Size: 1.05 KB
Versions: 8
Compression:
Stored size: 1.05 KB
Contents
# frozen_string_literal: true
require 'English'
require 'timeout'
require 'pathname'
module Shipit
class Flock
TimeoutError = Class.new(::Timeout::Error)
attr_reader :path
def initialize(path)
@path = Pathname.new(path)
@acquired = false
end
def lock(timeout:)
return yield if @acquired
path.parent.mkpath
path.open('w') do |file|
if retrying(timeout: timeout) { file.flock(File::LOCK_EX | File::LOCK_NB) }
file.write($PROCESS_ID.to_s)
@acquired = true
begin
yield
ensure
@acquired = false
end
else
raise TimeoutError, "Couldn't acquire lock for #{path} in #{timeout} seconds"
end
end
end
private
def retrying(timeout:, breathing_time: 0.01)
started_at = Time.now.to_f
loop do
if yield
return true
elsif Time.now.to_f - started_at < timeout
sleep(breathing_time)
else
return false
end
end
end
end
end
Version data entries
8 entries across 8 versions & 1 rubygems