Class: RubyReactor::Lock

Inherits:
Object
  • Object
show all
Defined in:
lib/ruby_reactor/lock.rb

Defined Under Namespace

Classes: AcquisitionError, ContextLockContention

Constant Summary collapse

MIN_EXTEND_INTERVAL =

Minimum interval between auto-extend pings; protects very small TTLs.

1.0

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(key, owner:, ttl: 60, wait: 0, auto_extend: true) ⇒ Lock

Returns a new instance of Lock.



25
26
27
28
29
30
31
32
33
 
# File 'lib/ruby_reactor/lock.rb', line 25

def initialize(key, owner:, ttl: 60, wait: 0, auto_extend: true)
  @key = "lock:#{key}"
  @owner = owner
  @ttl = ttl
  @wait = wait
  @auto_extend = auto_extend
  @extender = nil
  @extender_running = false
end

Instance Attribute Details

#auto_extend ⇒ Object (readonly)

Returns the value of attribute auto_extend.



23
24
25
 
# File 'lib/ruby_reactor/lock.rb', line 23

def auto_extend
  @auto_extend
end

#key ⇒ Object (readonly)

Returns the value of attribute key.



23
24
25
 
# File 'lib/ruby_reactor/lock.rb', line 23

def key
  @key
end

#owner ⇒ Object (readonly)

Returns the value of attribute owner.



23
24
25
 
# File 'lib/ruby_reactor/lock.rb', line 23

def owner
  @owner
end

#ttl ⇒ Object (readonly)

Returns the value of attribute ttl.



23
24
25
 
# File 'lib/ruby_reactor/lock.rb', line 23

def ttl
  @ttl
end

#wait ⇒ Object (readonly)

Returns the value of attribute wait.



23
24
25
 
# File 'lib/ruby_reactor/lock.rb', line 23

def wait
  @wait
end

Instance Method Details

#acquire ⇒ Object 



35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
 
# File 'lib/ruby_reactor/lock.rb', line 35

def acquire
  start_time = Process.clock_gettime(Process::CLOCK_MONOTONIC)

  loop do
    if adapter.lock_acquire(@key, @owner, @ttl)
      start_extender if @auto_extend
      return true
    end

    if @wait.zero? || (Process.clock_gettime(Process::CLOCK_MONOTONIC) - start_time) >= @wait
      raise AcquisitionError, "Could not acquire lock '#{@key}' for owner '#{@owner}'"
    end

    sleep 0.1
  end
end

#release ⇒ Object 



52
53
54
55
 
# File 'lib/ruby_reactor/lock.rb', line 52

def release
  stop_extender
  adapter.lock_release(@key, @owner)
end

#synchronize ⇒ Object 



57
58
59
60
61
62
 
# File 'lib/ruby_reactor/lock.rb', line 57

def synchronize
  acquire
  yield
ensure
  release
end