解决并发文件访问的一种常见方法是使用互斥锁(Mutex)来同步对文件的访问。
以下是一个使用互斥锁解决并发文件访问的示例代码:
import threading
# 创建互斥锁
file_lock = threading.Lock()
def write_to_file(filename, data):
# 获取互斥锁
file_lock.acquire()
try:
# 打开文件进行写入操作
with open(filename, 'a') as file:
file.write(data + '\n')
finally:
# 释放互斥锁
file_lock.release()
def read_from_file(filename):
# 获取互斥锁
file_lock.acquire()
try:
# 打开文件进行读取操作
with open(filename, 'r') as file:
lines = file.readlines()
for line in lines:
print(line.strip())
finally:
# 释放互斥锁
file_lock.release()
# 创建多个线程进行文件读写操作
write_thread = threading.Thread(target=write_to_file, args=('file.txt', 'Hello, World!'))
read_thread = threading.Thread(target=read_from_file, args=('file.txt',))
write_thread.start()
read_thread.start()
write_thread.join()
read_thread.join()
在上述示例中,我们使用了threading.Lock()
创建了一个互斥锁file_lock
。在写入文件时,通过调用file_lock.acquire()
获取互斥锁,然后进行文件写入操作,最后调用file_lock.release()
释放互斥锁。在读取文件时也是同样的逻辑。
使用互斥锁可以确保同一时间只有一个线程能够访问文件,从而解决了并发文件访问的问题。
上一篇:并发文件读写比单线程读写慢得多。
下一篇:并发文件夹遍历 Python