python fcntl如何处理并发访问 - 问答

fcntl 是 Python 中的一个库，用于处理文件描述符的锁定和解锁

以下是一个简单的示例，说明如何使用 fcntl 处理并发访问：

import os
import fcntl
import threading

# 定义一个锁文件路径
lock_file = "lockfile.lock"

def acquire_lock(lock_file):
    # 使用 'w' 模式打开文件，如果文件不存在则创建
    with open(lock_file, 'w') as f:
        # 使用 fcntl.flock() 获取文件锁定
        fcntl.flock(f, fcntl.LOCK_EX)  # 获取独占锁
        print(f"{threading.current_thread().name} 获取到锁")
        # 在这里执行需要同步的操作
        pass

def release_lock(lock_file):
    with open(lock_file, 'w') as f:
        # 使用 fcntl.flock() 释放文件锁定
        fcntl.flock(f, fcntl.LOCK_UN)  # 释放锁
        print(f"{threading.current_thread().name} 释放锁")

# 创建两个线程模拟并发访问
t1 = threading.Thread(target=acquire_lock, args=(lock_file,))
t2 = threading.Thread(target=acquire_lock, args=(lock_file,))
t3 = threading.Thread(target=release_lock, args=(lock_file,))

t1.start()
t2.start()
t3.start()

t1.join()
t2.join()
t3.join()

在这个示例中，我们创建了两个线程 t1 和 t2 来模拟并发访问。它们都尝试获取同一个锁文件（lockfile.lock）的独占锁。当 t1 获取到锁时，t2 将等待直到锁被释放。同样，当 t3 运行并释放锁时，t1 和 t2 中的任何一个都可以获取到锁并执行同步操作。

注意：这个示例仅用于演示目的，实际应用中可能需要根据具体需求进行调整。

0 赞

0 踩