4

我有一个Thread扩展类，应该一次只运行一个实例（跨进程）。为了实现这一点，我正在尝试使用文件锁。以下是我的一些代码：

class Scanner(Thread):

  def __init__(self, path):
    Thread.__init__(self)
    self.lock_file = open(os.path.join(config.BASEDIR, "scanner.lock"), 'r+')
    fcntl.lockf(self.lock_file, fcntl.LOCK_EX | fcntl.LOCK_NB)

  # Stuff omitted

  def run(self):
    logging.info("Starting scan on %s" % self.path)

    # More stuff omitted

    fcntl.lockf(self.lock_file, fcntl.LOCK_UN)

如果线程已经在运行并且根本没有初始化对象，我希望lockf调用会引发异常。Scanner但是，我可以在终端中看到：

INFO:root:Starting scan on /home/felix/Music
INFO:root:Starting scan on /home/felix/Music
INFO:root:Scan finished
INFO:root:Scan finished

这表明两个Scanner线程同时运行，没有抛出异常。我确定我在这里遗漏了一些非常基本的东西，但我似乎无法弄清楚那是什么。任何人都可以帮忙吗？

4

3 回答 3

3

最后自己找到了解决方案。它是用来fcntl.flock()代替fcntl.lockf(), 具有完全相同的参数。不知道为什么会有所作为。

于 2011-03-20T17:48:08.403 回答
2

您正在打开锁定文件，使用r+它会擦除以前的文件并创建一个新文件。每个线程都锁定一个不同的文件。

使用w或r+a

于 2011-03-20T17:00:11.767 回答
0

除了使用flock，我还必须像这样打开文件：

fd = os.open(lockfile, os.O_CREAT | os.O_TRUNC | os.O_WRONLY)

在其他方面它不起作用。

于 2013-08-26T10:14:31.390 回答