Python中使用FileLock()实现文件的读写并发控制

在Python中，可以使用FileLock模块来实现文件的读写并发控制。FileLock模块提供了FileLock类，用于在多个进程或线程之间对文件进行加锁和解锁操作。

下面是一个使用FileLock实现文件并发控制的示例：

import os
import time
from filelock import FileLock

# 定义一个文件路径
file_path = "test.txt"

# 获取文件锁对象
lock = FileLock(file_path + ".lock")

# 写入文件内容的函数
def write_file(content):
    with open(file_path, "a") as f:
        f.write(content + "
")

# 读取文件内容的函数
def read_file():
    with open(file_path, "r") as f:
        lines = f.readlines()
        for line in lines:
            print(line.strip())

# 获取文件锁
with lock.acquire(timeout=10):
    print("获取文件锁成功")

    # 写入文件
    write_file("Hello, World!")

    # 模拟处理耗时的操作
    time.sleep(5)

    # 读取文件内容
    read_file()

# 释放文件锁
lock.release()
print("释放文件锁")

在上面的示例中，我们首先导入了filelock模块，并定义了一个文件路径。然后我们通过FileLock(file_path + ".lock")创建了一个文件锁对象。

接下来，我们使用lock.acquire(timeout=10)来尝试获取文件锁，设置了一个超时时间10秒。如果成功获取到文件锁，就执行write_file函数将内容写入文件，然后模拟处理耗时的操作，最后调用read_file函数读取文件内容。

最后，我们使用lock.release()释放文件锁。

这样，我们就实现了对文件的读写并发控制。只有一个进程或线程能够获取到文件锁，其他进程或线程需要等待文件锁的释放才能执行相应的操作。

需要注意的是，在使用FileLock进行文件并发控制时，应该通过with语句来管理文件锁的获取和释放，以确保在使用完文件后能够正常释放文件锁。