Python fcntl未按预期锁定

在基于Debian的操作系统（Ubuntu，Debian Squeeze）上，我使用Python（2.7，3.2）fcntl来锁定文件。根据我所读到的内容，fnctl.flock以某种方式锁定文件，如果另一个客户端想要锁定同一个文件，就会引发异常。

我构建了一个小例子，我希望抛出一个excepiton，因为我首先锁定了文件，然后，立即，我尝试再次锁定它：

#!/usr/bin/env python
# -*- coding: utf-8 -*-
import fcntl
fcntl.flock(open('/tmp/locktest', 'r'), fcntl.LOCK_EX)
try:
    fcntl.flock(open('/tmp/locktest', 'r'), fcntl.LOCK_EX | fcntl.LOCK_NB)
except IOError:
    print("can't immediately write-lock the file ($!), blocking ...")
else:
    print("No error")

但是这个例子只显示"没有错误"。

如果我把这段代码分成两个同时运行的客户端（一个锁定然后等待，另一个在第一个锁已经激活后试图锁定），我会得到相同的行为——根本没有效果。

对这种行为的解释是什么？

编辑：

根据Nightcrack的要求进行更改，此版本还打印"无错误"，尽管我不希望：

#!/usr/bin/env python
# -*- coding: utf-8 -*-
import fcntl
import time
fcntl.flock(open('/tmp/locktest', 'w'), fcntl.LOCK_EX | fcntl.LOCK_NB)
try:
    fcntl.flock(open('/tmp/locktest', 'w'), fcntl.LOCK_EX | fcntl.LOCK_NB)
except IOError:
    print("can't immediately write-lock the file ($!), blocking ...")
else:
    print("No error")

旧帖子，但如果其他人找到了，我会得到这样的行为：

>>> fcntl.flock(open('test.flock', 'w'), fcntl.LOCK_EX)
>>> fcntl.flock(open('test.flock', 'w'), fcntl.LOCK_EX | fcntl.LOCK_NB)
# That didn't throw an exception
>>> f = open('test.flock', 'w')
>>> fcntl.flock(f, fcntl.LOCK_EX)
>>> fcntl.flock(open('test.flock', 'w'), fcntl.LOCK_EX | fcntl.LOCK_NB)
Traceback (most recent call last):
  File "<stdin>", line 1, in <module>
IOError: [Errno 35] Resource temporarily unavailable
>>> f.close()
>>> fcntl.flock(open('test.flock', 'w'), fcntl.LOCK_EX | fcntl.LOCK_NB)
# No exception

在第一种情况下，文件在第一行之后关闭，可能是因为文件对象不可访问。关闭文件将解除锁定。

我遇到了同样的问题。。。我已经解决了将打开的文件保存在一个单独的变量中的问题：

不起作用：

fcntl.lockf(open('/tmp/locktest', 'w'), fcntl.LOCK_EX | fcntl.LOCK_NB)

作品：

lockfile = open('/tmp/locktest', 'w')
fcntl.lockf(lockfile, fcntl.LOCK_EX | fcntl.LOCK_NB)

我认为第一个不起作用，因为打开的文件被垃圾收集，关闭并且锁被释放。

明白了。我的脚本中的错误是，我在每次调用时都创建了一个新的文件描述符：

fcntl.flock(open('/tmp/locktest', 'r'), fcntl.LOCK_EX | fcntl.LOCK_NB)
(...)
fcntl.flock(open('/tmp/locktest', 'r'), fcntl.LOCK_EX | fcntl.LOCK_NB)

相反，我必须将文件对象分配给一个变量，然后尝试锁定：

f = open('/tmp/locktest', 'r')
fcntl.flock(f, fcntl.LOCK_EX | fcntl.LOCK_NB)
(...)
fcntl.flock(f, fcntl.LOCK_EX | fcntl.LOCK_NB)

我也得到了我想看到的例外：IOError: [Errno 11] Resource temporarily unavailable。现在我必须考虑在哪些情况下使用fcntl是有意义的。

有两个捕获。根据文件：

当操作为LOCK_SH或LOCK_EX时，它也可以与LOCK_NB进行位"或"运算，以避免锁定获取时的阻塞。如果使用了LOCK_NB并且无法获取锁，则会引发IOError，并且异常的errno属性将设置为EACCES或EAGAIN（取决于操作系统；为了便于移植，请检查这两个值）。

您忘记设置LOCK_NB。
至少在某些系统上，只有当文件描述符引用为写入而打开的文件时，才能使用LOCK_EX。

您打开了一个文件进行读取，该文件在您的系统上可能不支持LOCK_EX。

您可以参考这篇文章来了解不同锁定方案的更多详细信息
至于您的第二个问题，使用fcntl在不同的进程中获得锁定（为了简单起见，请使用lockf）。在linux上，lockf只是fcntl的包装器，两者都与(pid, inode)对相关联
1.使用fcntl.fcntl提供跨进程的文件锁定。

import os
import sys
import time
import fcntl
import struct

fd = open('/etc/mtab', 'r')
ppid = os.getpid()
print('parent pid: %d' % ppid)
lockdata = struct.pack('hhllh', fcntl.F_RDLCK, 0, 0, 0, ppid)
res = fcntl.fcntl(fd.fileno(), fcntl.F_SETLK, lockdata)
print('put read lock in parent process: %s' % str(struct.unpack('hhllh', res)))
if os.fork():
    os.wait()
    lockdata = struct.pack('hhllh', fcntl.F_UNLCK, 0, 0, 0, ppid)
    res = fcntl.fcntl(fd.fileno(), fcntl.F_SETLK, lockdata)
    print('release lock: %s' % str(struct.unpack('hhllh', res)))
else:
    cpid = os.getpid()
    print('child pid: %d' % cpid)
    lockdata = struct.pack('hhllh', fcntl.F_WRLCK, 0, 0, 0, cpid)
    try:
        fcntl.fcntl(fd.fileno(), fcntl.F_SETLK, lockdata)
    except OSError:
        res = fcntl.fcntl(fd.fileno(), fcntl.F_GETLK, lockdata)
        print('fail to get lock: %s' % str(struct.unpack('hhllh', res)))
    else:
        print('succeeded in getting lock')

2.使用fcntl.lockf。

import os
import time
import fcntl
fd = open('/etc/mtab', 'w')
fcntl.lockf(fd, fcntl.LOCK_EX | fcntl.LOCK_NB)
if os.fork():
    os.wait()
    fcntl.lockf(fd, fcntl.LOCK_UN)
else:
    try:
        fcntl.lockf(fd, fcntl.LOCK_EX | fcntl.LOCK_NB)
    except IOError as e:
        print('failed to get lock')
    else:
        print('succeeded in getting lock')

您需要传入文件描述符（可通过调用文件对象的fileno（）方法获得）。当相同的代码在单独的解释器中运行时，下面的代码抛出IOError。

>>> import fcntl
>>> thefile = open('/tmp/testfile')
>>> fd = thefile.fileno()
>>> fcntl.flock(fd, fcntl.LOCK_EX | fcntl.LOCK_NB)

尝试：

global f
f = open('/tmp/locktest', 'r')

文件关闭后，锁将消失。

相关内容

最新更新

热门标签：