11

我应该如何申请非阻塞锁?

当单独尝试锁定文件时,为什么 Ruby 的File#flock不能按预期工作?将文件锁定在块中并不是解决此问题的正确解决方案,因为重点是显示锁定持久锁的行为。在块内使用 File#flock 会在块退出时释放锁,因此它不能正确演示问题。

File#flock 以多种方式失败,尤其是在请求非阻塞锁时。下面是一些例子。

File#flock 的失败示例

  • 使用多个独占锁时无限等待,因为#flock 不提供超时锁请求的方法。

    # First lock succeeds.
    f1 = File.open('foo', File::RDWR|File::CREAT, 0644)
    f1.flock(File::LOCK_EX)
    # => 0
    
    # This never returns.
    f2 = File.open('foo', File::RDWR|File::CREAT, 0644)
    f2.flock(File::LOCK_EX)
    
  • 在文件被独占锁定时请求非阻塞锁定会导致无效参数异常。

    f1 = File.open('foo', File::RDWR|File::CREAT, 0644)
    f1.flock(File::LOCK_EX)
    # => 0
    
    f2 = File.open('foo', File::RDWR|File::CREAT, 0644)
    f2.flock(File::LOCK_NB)
    # => Errno::EINVAL: Invalid argument - foo
    
  • 文档说#flock“根据locking_constant(下表中的逻辑或值)锁定或解锁文件。” 但是,逻辑或会引发Errno::EINVALErrno::EBADF取决于平台。

    f1 = File.open('foo', File::RDWR|File::CREAT, 0644)
    f1.flock(File::LOCK_EX)
    # => 0
    
    f2 = File.open('foo', File::RDWR|File::CREAT, 0644)
    f2.flock(File::LOCK_NB || File::LOCK_EX)
    # => Errno::EINVAL: Invalid argument - foo
    

Native File#flock 解决方案首选

虽然在无法获得独占锁时可能会使用Timeout 模块来引发Timeout::Error,但似乎 File#flock 应该能够本机解决这个问题。那么,实际上应该如何在不阻塞的情况下请求独占锁呢?

4

1 回答 1

17

使用带有排他锁的超时模块

您可以使用Timeout 模块设置#flock 获取排他锁的持续时间。下面的示例将 raise Timeout::Error: execution expired,然后可以以任何适合应用程序的方式来拯救它。计时器到期时返回nil允许测试 #flock 表达式的真实性。

require 'timeout'

f1 = File.open('foo', File::RDWR|File::CREAT, 0644)
f1.flock(File::LOCK_EX)
# => 0

f2 = File.open('foo', File::RDWR|File::CREAT, 0644)
Timeout::timeout(0.001) { f2.flock(File::LOCK_EX) } rescue nil
# => nil

对非阻塞锁尝试使用按位或

File#flock的文档说:

根据locking_constant(下表中的逻辑或值)锁定或解锁文件。如果指定了 File::LOCK_NB,则返回 false,否则操作将被阻止。

但是,该方法实际上需要按位 OR运算符,而不是parse.y 中由 tOROP 解析器令牌定义的逻辑 OR 关键字。因此,false当排他锁失败时,允许 #flock 返回的正确参数实际上是File::LOCK_NB|File::LOCK_EX. 例如:

f1 = File.open('foo', File::RDWR|File::CREAT, 0644)
f1.flock(File::LOCK_EX|File::LOCK_NB)
# => 0

f2 = File.open('foo', File::RDWR|File::CREAT, 0644)
f2.flock(File::LOCK_NB|File::LOCK_EX)
# => false

f1.close; f2.close
# => nil

这将在可用时始终生成排他锁;否则,它会立即返回一个虚假值,而无需引发或挽救异常的开销。这显然是该模块的使用方式,但文档可以使用一些说明和附加示例使其更易于理解。

于 2013-03-08T23:04:54.260 回答