python 多线程读写文件_Python多线程同步---文件读写控制方法

1、实现文件读写的文件ltz_schedule_times.py

#! /usr/bin/env python

#coding=utf-8

import os

def 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_times

def 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-8

from threading import Thread

import threading

import time

from ltz_schedule_times import *

#1、不加锁

def lock_test():

time.sleep(0.1)

schedule_times = ReadTimes()

print schedule_times

schedule_times = schedule_times + 1

WriteTimes(schedule_times)

if __name__ == '__main__':

for i in range(5):

Thread(target = lock_test, args=()).start()

得到结果：

write schedule_times start!

write schedule_times finish!

tmp: tmp: tmp: tmp: [[[['1''1''1''1']]]]

write schedule_times start!write schedule_times start!

write schedule_times finish!

write schedule_times finish!write schedule_times finish!

文件写入结果：

以上结果可以看出，不加锁多线程读写文件会出现错误。

2.2、加锁对文件进行多线程读写。

file_lock.py

#! /usr/bin/env python

#coding=utf-8

from threading import Thread

import threading

import time

from 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()

结果：

write schedule_times start!

write schedule_times finish!

tmp: ['1']

write schedule_times start!

write schedule_times finish!

tmp: ['1', '2']

write schedule_times start!

write schedule_times finish!

tmp: ['1', '2', '3']

write schedule_times start!

write schedule_times finish!

tmp: ['1', '2', '3', '4']

write schedule_times start!

write schedule_times finish!

文件写入结果：

以上这篇Python多线程同步---文件读写控制方法就是小编分享给大家的全部内容了，希望能给大家一个参考，也希望大家多多支持脚本之家。

python 多线程读写文件_Python多线程同步---文件读写控制方法相关推荐

python 多线程读写文件_python多线程同步之文件读写控制
本文实例为大家分享了python多线程同步之文件读写控制的具体代码,供大家参考,具体内容如下 1.实现文件读写的文件ltz_schedule_times.py #! /usr/bin/env pyth ...
python多线程下载多个文件_python多线程下载文件练习1
***今天在我BF的帮助下完成了小小的程序,也是我第一次写博客呢,谢谢他哦嘎嘎 1.首先,计算出下载文件的长度. conn = urllib.urlopen(url) headers = conn.i ...
python多线程处理文件_python多线程分块读取文件
# _*_coding:utf-8_*_ import time, threading, ConfigParser ''' Reader类,继承threading.Thread @__init__方法 ...
python多线程数据交互_python 多线程通信
一篇文章搞定Python多进程(全) 公众号:pythonislover 前面写了三篇关于python多线程的文章,大概概况了多线程使用中的方法,文章链接如下: 一篇文章搞懂Python多线程简单实现 ...
python爬取天天基金_python多线程+代理池爬取天天基金网、股票数据过程解析
简介提到爬虫,大部分人都会想到使用Scrapy工具,但是仅仅停留在会使用的阶段.为了增加对爬虫机制的理解,我们可以手动实现多线程的爬虫过程,同时,引入IP代理池进行基本的反爬操作. 本次使用天天基金 ...
python读取手机文件_python 读取网络文件
Python之pandas数据加载.存储 Python之pandas数据加载.存储 0. 输入与输出大致可分为三类: 0.1 读取文本文件和其他更好效的磁盘存储格式 2.2 使用数据库中的数据 0.3 ...
python web框架多线程和多进程_python 多线程和多进程
多线程与多进程知识预览一进程与线程的概念二 threading模块三 multiprocessing模块四协程五 IO模型回到顶部一进程与线程的概念 1.1 进程考虑一个场景: ...
python实用程序育儿法_Python多线程简明例子
Python多线程简明例子 (2010-03-11 15:15:09) Python多线程简明例子综述多线程是程序设计中的一个重要方面,尤其是在服务器Deamon程序方面.无论何种系统,线程调 ...
python真正实现多线程的方法_python多线程几种方法实现
匿名用户 1级 2018-05-27 回答 Python进阶(二十六)-多线程实现同步的四种方式临界资源即那些一次只能被一个线程访问的资源,典型例子就是打印机,它一次只能被一个程序用来执行打印功能, ...

python 多线程读写文件_Python多线程同步---文件读写控制方法

python 多线程读写文件_Python多线程同步---文件读写控制方法相关推荐

最新文章

热门文章