Python中利用FileLock()实现文件的读写互斥与并发

在Python中，可以使用FileLock库实现文件的读写互斥与并发控制。FileLock库提供了FileLock类，可以用来锁定文件并防止并发操作。

下面是一个使用FileLock实现文件读写互斥的例子：

import os
import time
from filelock import FileLock

# 创建文件锁
file_lock = FileLock("data.txt.lock")

# 定义文件路径
file_path = "data.txt"

# 读取数据
def read_data():
    # 加上文件锁
    with file_lock:
        with open(file_path, "r") as file:
            data = file.read()
            print(f"Reading data: {data}")
            time.sleep(1)

# 写入数据
def write_data(data):
    # 加上文件锁
    with file_lock:
        with open(file_path, "w") as file:
            file.write(data)
            print(f"Writing data: {data}")
            time.sleep(1)

# 主函数
if __name__ == "__main__":
    # 创建并启动3个读线程
    for i in range(3):
        os.fork()
        read_data()

    # 写入数据
    for i in range(3):
        os.fork()
        write_data(f"Data {i}")

在上面的例子中，文件锁使用FileLock类创建，并传入要锁定的文件路径。然后使用with语句来加锁和释放锁，在文件读写操作前后加上锁可以确保文件的读写是互斥的。

在主函数中，可以创建多个读线程和写线程。通过fork()函数创建子进程，模拟并发的读写操作。

值得注意的是，FileLock只能在同一个进程中控制并发访问，如果需要在不同进程之间控制并发访问，可以使用LockFile库。

以上是利用FileLock实现文件的读写互斥与并发的例子，通过加锁可以确保文件的读写操作是互斥的，并且可以实现并发访问控制，避免数据不一致的问题。