python多线程多进程运行场景（Python多线程同步---文件读写控制方法）
时间：2022-03-30 00:48:03 类别：脚本大全 浏览量：1769
python多线程多进程运行场景
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 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']]]]111 1write 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']1write schedule_times start!write schedule_times finish!tmp: ['1', '2']2write schedule_times start!write schedule_times finish!tmp: ['1', '2', '3']3write schedule_times start!write schedule_times finish!tmp: ['1', '2', '3', '4']4write schedule_times start!write schedule_times finish! |
文件写入结果：
以上这篇python多线程同步---文件读写控制方法就是小编分享给大家的全部内容了，希望能给大家一个参考，也希望大家多多支持开心学习网。
原文链接：https://blog.csdn.net/will130/article/details/50599577
您可能感兴趣
- laravel多线程处理请求（Laravel 6 将新增为指定队列任务设置中间件的功能）
- python计算csv的行数（对Python 多线程统计所有csv文件的行数方法详解）
- linux多线程怎么设置（超详细讲解Linux C++多线程同步的方式）
- python多线程有两个参数怎么传（python从子线程中获得返回值的方法）
- python多线程多种方法（详解python多线程之间的同步一）
- python开启多线程（python 多线程重启方法）
- phpcurl请求能在日志里记录吗（php使用curl模拟多线程实现批处理功能示例）
- python的多线程比多进程效率高（Python中单线程、多线程和多进程的效率对比实验实例）
- python多线程实现（python多线程并发让两个LED同时亮的方法）
- python中的多线程详解（python多线程抽象编程模型详解）
- python线程池如何实现同步（Python mutiprocessing多线程池pool操作示例）
- python多线程超时设置（解决python线程卡死的问题）
- python多进程与多线程详解（Python线程之定位与销毁的实现）
- ftp上传工具使用方法（CuteFTP多线程FTP上传下载工具功能介绍）
- python多线程多进程运行场景（Python多线程同步---文件读写控制方法）
- python 多线程与多进程（python 多线程串行和并行的实例）
- 今天会下雨吗（今天会下雨吗小说）
- 追连续剧，品古今联4 明代三杨，联妙诗佳（追连续剧品古今联4）
- 三杨 共辅四朝帝王，构建明帝国内阁行政圈（三杨共辅四朝帝王）
- 红色文化进国企（红色文化进国企）
- 车友的选择| 轮毂该如何选（车友的选择轮毂该如何选）
- 秦海璐炫耀和王新军热恋蜜事，不料对方吐槽她吃饱后肚子撅老高（秦海璐炫耀和王新军热恋蜜事）
热门推荐
- linux启动jenkins（linux 下jenkins项目搭建过程centos7为例 ）
- c# 注册表操作
- 为什么网页不显示css效果（网页布局中CSS样式无效的十个重要原因详解）
- css3伸缩布局及图解（利用CSS3实现自定义滚动条代码分享）
- Ext.query与Ext.select 的用法
- 免备案服务器云服务器（香港免备案云服务器的优势有哪些？）
- css3背景制作（纯CSS3实现Material Design效果）
- electronvue最新版本（Vue3和Electron实现桌面端应用详解）
- docker重新加载nginx（Docker Nginx Log 三者的处理详解）
- sql查询地址中包含某个字段（SQL查询字段被包含语句）
排行榜
- 1
- 2
- 3
- 4
- 5
- 6
- 7
- 8
- 9