Coin163

首页 > Python多线程同步---文件读写控制

Python多线程同步---文件读写控制

相关标签: python 多线程

2021腾讯云限时秒杀,爆款1核2G云服务器298元/3年!(领取2860元代金券),
地址https://cloud.tencent.com/act/cps/redirect?redirect=1062

2021阿里云最低价产品入口+领取代金券(老用户3折起),
入口地址https://www.aliyun.com/minisite/goods

相关推荐:Python标准库08 多线程与同步 (threading包)

Python标准库08 多线程与同步 (threading包)   Python主要通过标准库中的threading包来实现多线程。在当今网络时代,每个服务器都会接收到大量的请求。服务器可以利用多线程的方式来处理这些请求,以提高对网络端口的读写效率。Python是一种网络服务器的后台

1、实现文件读写的文件ltz_schedule_times.py #! /usr/bin/env python#coding=utf-8import osdef ReadTimes():

res = []

if os.path.exists('schedule_times.txt'):

fp = open('schedule_times.txt', 'r')

else:

os.system('touch schedule_times.txt')

fp = open('schedule_times.txt', 'r')

try:

line = fp.read()

if line == None or len(line)==0:

fp.close()

return 0

tmp = line.split()

print 'tmp: ', tmp

schedule_times = int(tmp[-1])

finally:

fp.close()

#print schedule_times

return schedule_timesdef WriteTimes(schedule_times):

if schedule_times <= 10:

fp = open('schedule_times.txt', 'a+')#10以内追加进去

else:

fp = open('schedule_times.txt', 'w')#10以外重新写入

schedule_times = 1

print 'write schedule_times start!'

try:

fp.write(str(schedule_times)+'\n')

finally:

fp.close()

print 'write schedule_times finish!'if __name__ == '__main__':

schedule_times = ReadTimes()

#if schedule_times > 10:

# schedule_times = 0

print schedule_times

schedule_times = schedule_times + 1

WriteTimes(schedule_times) 2.1、不加锁对文件进行多线程读写。file_lock.py #! /usr/bin/env python#coding=utf-8from threading import Threadimport threadingimport timefrom ltz_schedule_times import *#1、不加锁def lock_test():

time.sleep(0.1)

schedule_times = ReadTimes()

print schedule_times

schedule_times = schedule_times +

相关推荐:多线程同步

1 多线程的问题

多个线程执行方式为轮询执行

A停止 -> B开始 -〉B停止 -> A开始

当线程停止会保存寄存器的状态。(压入栈中)

当线程开始会恢复寄存器的状态。(从栈中取出)

AB线程都使用printf的问题:

A线程调用print

1

WriteTimes(schedule_times)if __name__ == '__main__':

for i in range(5):

Thread(target = lock_test, args=()).start() 得到结果: 0write schedule_times start! write schedule_times finish! tmp: tmp: tmp: tmp: [[[['1''1''1''1']]]] 11 1 1 write schedule_times start!write schedule_times start! write schedule_times start!write schedule_times start! write schedule_times finish! write schedule_times finish! write schedule_times finish!write schedule_times finish! 文件写入结果: 以上结果可以看出,不加锁多线程读写文件会出现错误。 2.2、加锁对文件进行多线程读写。file_lock.py #! /usr/bin/env python#coding=utf-8from threading import Threadimport threadingimport timefrom ltz_schedule_times import *#2、加锁mu = threading.Lock() #1、创建一个锁def lock_test():

#time.sleep(0.1)

if mu.acquire(True): #2、获取锁状态,一个线程有锁时,别的线程只能在外面等着

schedule_times = ReadTimes()

print schedule_times

schedule_times = schedule_times + 1

WriteTimes(schedule_times)

mu.release() #3、释放锁 if __name__ == '__main__':

for i in range(5):

Thread(target = lock_test, args=()).start() 结果: 0write schedule_times start! write schedule_times finish! tmp: ['1'] 1 write schedule_times start! write schedule_times finish! tmp: ['1', '2'] 2 write schedule_times start! write schedule_times finish! tmp: ['1', '2', '3'] 3 write schedule_times start! write schedule_times finish! tmp: ['1', '2', '3', '4'] 4 write schedule_times start! write schedule_times finish! 文件写入结果: 达到读写效果。

原文

1、实现文件读写的文件ltz_schedule_times.py #! /usr/bin/env python#coding=utf-8import osdef ReadTimes(): res = [] if os.path.exists('schedule_times.txt'): fp = o

------分隔线----------------------------