阅读量:0
在Python中,可以使用threading
模块来实现多线程操作,使用threading.Lock()
来创建一个锁对象。
下面是一个示例代码,演示了如何使用多线程写文件并加锁:
import threading def write_file(lock, filename, content): # 获取锁 lock.acquire() try: with open(filename, 'a') as f: f.write(content + '\n') finally: # 释放锁 lock.release() if __name__ == '__main__': # 创建一个锁对象 lock = threading.Lock() # 创建多个线程,并启动 threads = [] for i in range(5): t = threading.Thread(target=write_file, args=(lock, 'test.txt', f'Thread {i}')) threads.append(t) t.start() # 等待所有线程结束 for t in threads: t.join()
在上面的代码中,write_file()
函数用于写入文件,其中lock.acquire()
用于获取锁,lock.release()
用于释放锁。在每个线程中,先获取锁,执行写文件操作,然后释放锁,以确保每个线程在写文件时都是互斥的。
注意,在使用锁时,需要确保在获取锁后的代码块中,如果发生异常也能正常释放锁,通常使用try...finally
来确保锁的释放。