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
中的任何一个都可以获取到锁并执行同步操作。
注意:这个示例仅用于演示目的,实际应用中可能需要根据具体需求进行调整。