乱序多线程写入
举个最简单的例子,只要求快速写入即可,对顺序无要求时:
import threading
def write_string(string, path="test.csv"):
with open(path, 'a') as f:
f.write(string + "\r\n")
# 创建新线程
for i in range(15):
# 这里每次循环都开一个线程,并写入"写入:" + i,args里指定参数,注意要使用list[]格式
thread1 = threading.Thread(target=write_string, args=["写入: " + str(i)])
thread1.start()
或是使用:
import threading
class WriteThread(threading.Thread):
def __init__(self, string, file_path):
threading.Thread.__init__(self)
self.string = string
self.file_path = file_path
def run(self):
write_string(self.file_path, self.string)
def write_string(file_path, string):
with open(file_path, 'a') as f:
f.write(string + "\r\n")
for i in range(15):
thread1 = WriteThread("写入:" + str(i), "test.csv")
thread1.start()
正序多线程写入
只需要改动三行:
import threading
threadLock = threading.Lock()
def write_string(string, path="test.csv"):
threadLock.acquire() # 加个同步锁就好了
with open(path, 'a') as f:
f.write(string + "\r\n")
threadLock.release()
# 创建新线程
for i in range(15):
thread1 = threading.Thread(target=write_string, args=["写入: " + str(i)]).run()
今天的文章python多线程飞速写入文件分享到此就结束了,感谢您的阅读。
版权声明:本文内容由互联网用户自发贡献,该文观点仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 举报,一经查实,本站将立刻删除。
如需转载请保留出处:https://bianchenghao.cn/11327.html