孤荷凌寒自学python第四十一天python的线程同步之Event对象

(完整学习过程屏幕记录视频地址在文末,手写笔记在文末)

鉴于Lock锁与RLock锁均宣告没有完全完成同步文件操作的问题,于是进一步初步了解了Event对象。

一、  得到Event对象

新的Event对象=threading. Event()

使用Event类的初始化方法之前,必须保证当前py文档已声明引用过threading模块:

import threading

二、  Event对象的主要方法

Event对象有三个主要的方法:(具体用法在下文再详细笔记)

1

Event对象 . set()

2

Event对象 . wait()

3

Event对象 . clear()

三、  Event对象的标识(flag)状态

1

flag=False 这 Event对象的默认状态,此时线程的执行不受影响。

2

flag=True 这是Event对象执行了set()方法后的状态,这种状态表示,如果线程当前于于wait(等待)状态中,现在就可以恢复运行了。

3

wait状态

如果 在线程中执行了Event对象的wait()方法,那么此线程就处于wait状态,等待flag=True状态的出现后,才能继续运行。

四、  恢复Event对象的状态为默认状态的方法

执行:

Event对象.clear()

方法就会将Event对象的状态恢复为默认状态。

五、  获取Event对象的当前状态标识(flag)

状态flag=Event对象.is_set()

状态flag=Event对象.isSet()

这两个方法效果等同,都将返回一个布尔对象。

以上方法无法得知某个线程是否处在等待状态中,因为,一个Event对象可以同时出现在多个线程中,因此想知道哪些个线程处于等待状态中,对于Event对象来说是不明确的。目前我对Event对象的学习不够深入,也没有了解可以完成此检验的其它方法。

六、  将文件由两个线程反复同步写和读的实现由Event对象来实现

最开始是在读线程和写线程中分别 使用独立的Event对象来进行运作,代码如下:

importthreading

fromdatetime import datetime

from time import sleep

strf='1.txt'

def read():

n=3

while n:

ifEwrite.isSet()==True: #如果其它线程没有处于锁定执行状态

Eread.wait()

with open(strf,'r',encoding='utf-8') as f:

lstA=f.readlines()

print('读取第' + str(n) + '次' + str(lstA) +str(Ewrite.isSet()) + '\n')

Ewrite.set()

#Eread.clear()

n-=1

def write():

n=3

while n:

ifEread.isSet()==True:

Ewrite.wait()

with open(strf,'w',encoding='utf-8') as f:

lstA=['写入','第' + str(n) + '次' + str(Eread.isSet())+ '\n']

print(lstA)

f.writelines(lstA)

Eread.set()

#Ewrite.clear()

n-=1

def main():

tread=threading.Thread(target=read)

twrite=threading.Thread(target=write)

twrite.start()

tread.start()

#Eread.set()

twrite.join()

tread.join()

print('主线程结束。')

if __name__=='__main__':

Eread=threading.Event()

Ewrite=threading.Event()

main()

运行结果如下,证实没有成功:

['写入', '第3次False\n']

读取第3次[]False

['写入', '第2次True\n']

读取第2次[]True

['写入', '第1次True\n']

读取第1次[]True

从结果中看出,三次写入是成功的,且读写交替进行,符合同步要求,但证实在同步读写同一个文件时,还是出现了冲突,因为读的三次,一次都没有取出内容来。

于是修改代码为在两个线程中都使用同一个Event对象来控制:

下面是代码,特别注意注释部分。

importthreading

fromdatetime import datetime

from time import sleep

strf='1.txt'

def read():

n=3

while n:

ifE.isSet()==True: #如果Event对象已经执行过set方法了,那么,read可以利用此间隙运行,因为write已经运行结束,没有占用要读的文件

pass

else:

E.wait()

#E.clear()

with open(strf,'r',encoding='utf-8') as f:

lstA=f.readlines()

#读文件的时候,尽快将文件中的内容读取出来 ,就马上离开with语句块,使操作的文件尽快关闭。

# 意思就是说,不要在操作文件的with语句块中放太多语句,全要操作的文件处于独占打开模式,这会影响其它进程对同一文件的操作。

sleep(1)

print('读取第' + str(n) + '次' + str(lstA) +str(E.isSet()) + '\n')

E.set()

n-=1

def write():

n=3

while n:

ifE.isSet()==True: #如果Event对象已经执行过set方法了,那么,write可以利用此间隙运行,因为read已经运行结束,没有占用要读的文件

pass

else:

E.wait()

#E.clear()

with open(strf,'w',encoding='utf-8') as f:

lstA=['写入','第' + str(n) + '次' + str(E.isSet())]

f.writelines(lstA)

sleep(1)

print(str(lstA) +'\n')

E.set()

n-=1

def main():

tread=threading.Thread(target=read)

twrite=threading.Thread(target=write)

tread.start()

twrite.start()

E.set()

twrite.join()

tread.join()

print('主线程结束。')

if __name__=='__main__':

E=threading.Event()

main()

运行结果如下:

['写入','第3次True']

读取第3次['写入第3次True']True

 

 

['写入','第2次True']

读取第2次['写入第2次True']True

 

 

['写入','第1次True']

读取第1次['写入第1次True']True

从执行结果中看出,终于实现了预定的测试目标:读写交替进行,读和写都能正确完成,说明文件在同一时间只有一个线程在操作使用,没有发生冲突。

——————————

今天整理的学习笔记完成,最后例行说明下我的自学思路:

根据过去多年我自学各种编程语言的经历,认为只有真正体验式,解决实际问题式的学习才会有真正的效果,即让学习实际发生。在2004年的时候我开始在一个乡村小学自学电脑 并学习vb6编程语言,没有学习同伴,也没有高师在上,甚至电脑都是孤岛(乡村那时还没有网络),有的只是一本旧书,在痛苦的自学摸索中,我找到适应自己零基础的学习方法:首先是每读书的一小节就作相应的手写笔记,第二步就是上机测试每一个笔记内容是否实现,其中会发现书中讲的其实有出入或错误,第三步就是在上机测试之后,将笔记改为电子版,形成最终的修订好的正确无误的学习笔记。

通过反复尝试错误,在那个没有分享与交流的黑暗时期我摸黑学会了VB6,尔后接触了其它语言,也曾听过付费视频课程,结果发现也许自己学历果然太低,就算是零基础的入门课程,其实也难以跟上进度,讲师的教学多数出现对初学者的实际情况并不了解的情况,况且学习者的个体也存在差异呢?当然更可怕的是收费课程的价格往往是自己难以承受的。

于是我的所有编程学习都改为了自学,继续自己的三步学习笔记法的学习之路。

当然自学的最大问题是会走那么多的弯路,没有导师直接输入式的教学来得直接,好在网络给我们带来无限搜索的机会,大家在网络上的学习日志带给我们共享交流的机会,而QQ群等交流平台、网络社区的成立,我们可以一起自学,互相批评交流,也可以获得更有效,更自主的自学成果。

于是我以人生已过半的年龄,决定继续我的编程自学之路,开始学习python,只希望与大家共同交流,一个人的独行是可怕的,只有一群人的共同前进才是有希望的。

诚挚期待您的交流分享批评指点!欢迎联系我加入从零开始的自学联盟。

这个时代互联网成为了一种基础设施的存在,于是本来在孤独学习之路上的我们变得不再孤独,因为网络就是一个新的客厅,我们时刻都可以进行沙龙活动。

非常乐意能与大家一起交流自己自学心得和发现,更希望大家能够对我学习过程中的错误给予指点——是的,这样我就能有许多免费的高师了——这也是分享时代,社区时代带来的好福利,我相信大家会的,是吧!

根据完全共享的精神,开源互助的理念,我的个人自学录制过程是全部按4K高清视频录制的,从手写笔记到验证手写笔记的上机操作过程全程录制,但因为4K高清文件太大均超过5G以上,所以无法上传至网络,如有需要可联系我QQ578652607对传,乐意分享。上传分享到百度网盘的只是压缩后的720P的视频。

我的学习过程录像百度盘地址分享如下:(清晰度:1280x720)

链接:https://pan.baidu.com/s/1Wi8XgCMMdttN6bX4SAngHQ

提取码:77e4

Bilibili:

https://www.bilibili.com/video/av38090327/

喜马拉雅语音笔记:

https://www.ximalaya.com/keji/19103006/145700746

转载于:https://www.cnblogs.com/lhghroom/p/10140512.html

孤荷凌寒自学python第四十一天python的线程同步之Event对象相关推荐

  1. 孤荷凌寒自学python第三十八天初识python的线程控制

    孤荷凌寒自学python第三十八天初识python的线程控制 (完整学习过程屏幕记录视频地址在文末,手写笔记在文末) 一.线程 在操作系统中存在着很多的可执行的应用程序,每个应用程序启动后,就可以看着 ...

  2. 孤荷凌寒自学python第六天 列表的嵌套与列表的主要方法

    孤荷凌寒自学python第六天 列表的嵌套与列表的主要方法 (完整学习过程屏幕记录视频地址在文末,手写笔记在文末) (同步的语音笔记朗读:https://www.ximalaya.com/keji/1 ...

  3. 孤荷凌寒自学python第八十一天学习爬取图片1

    孤荷凌寒自学python第八十一天学习爬取图片1 (完整学习过程屏幕记录视频地址在文末) 通过前面十天的学习,我已经基本了解了通过requests模块来与网站服务器进行交互的方法,也知道了Beauti ...

  4. 孤荷凌寒自学python第五十四天使用python来删除Firebase数据库中的文档

    孤荷凌寒自学python第五十四天使用python来删除Firebase数据库中的文档 (完整学习过程屏幕记录视频地址在文末) 今天继续研究Firebase数据库,利用google免费提供的这个数据库 ...

  5. python 保存文件 吃内存_孤荷凌寒自学python第三十七天python的文件与内存变量之间的序列化与反序列化...

    孤荷凌寒自学python第三十七天python的文件与内存变量之间的序列化与反序列化 (完整学习过程屏幕记录视频地址在文末,手写笔记在文末) 一.什么是序列化与反序列化 序列化是指将内存中的数据进行指 ...

  6. 孤荷凌寒自学python第六十三天学习mongoDB的基本操作并进行简单封装2

    孤荷凌寒自学python第六十三天学习mongoDB的基本操作并进行简单封装2 (完整学习过程屏幕记录视频地址在文末) 今天是学习mongoDB数据库的第九天. 今天继续学习mongoDB的简单操作, ...

  7. 孤荷凌寒自学python第七十九天开始写Python的第一个爬虫9并使用pydocx模块将结果写入word文档...

    孤荷凌寒自学python第七十九天开始写Python的第一个爬虫9 (完整学习过程屏幕记录视频地址在文末) 今天在上一天的基础上继续完成对我的第一个代码程序的书写. 到今天终于完成了对docx模块针对 ...

  8. 孤荷凌寒自学python第四十五天Python初学基础基本结束的下阶段预安装准备

    孤荷凌寒自学python第四十五天Python初学基础基本结束的下阶段预安装准备 (完整学习过程屏幕记录视频地址在文末,手写笔记在文末) 今天本来应当继续学习Python的数据库操作,但根据过去我自学 ...

  9. python线程同步condition_042孤荷凌寒自学python线程同步之Condition对象

    孤荷凌寒自学python第四十二天python 的线程同步之Condition对象 (完整学习过程屏幕记录视频地址在文末,手写笔记在文末) 今天学习了Condition对象,发现它综合了Event对象 ...

最新文章

  1. 关于redis的几件小事(三)redis的数据类型与使用场景
  2. caffe源码分析:layer.hpp分析
  3. http 和 https_详解http和https的区别
  4. 一张图搞懂容器所有操作 - 每天5分钟玩转 Docker 容器技术(26)
  5. 563. 二叉树的坡度
  6. Zabbix 企业级监控
  7. Hibernate 一对一注释
  8. Android studio 运行即打包keystore之build.gradle设置
  9. flask带有传入参数既有URL还有其他参数类型:建议使用方式二(flask 使用查询字符串的方式)
  10. 【LOJ】#3030. 「JOISC 2019 Day1」考试
  11. 【华为云技术分享】一文掌握5种常用的机器学习模型及其优缺点
  12. GCC编译器简明教程(Linux下C语言开发环境的搭建)
  13. 背景复合写法(HTML、CSS)
  14. 图像频域增强:带通带阻滤波器
  15. 推荐一款专业串烧歌曲的音乐合并软件
  16. ZoomIt v4.5
  17. 中国软件企业排名(不是绝对的)
  18. 交换机crc错误是什么意思_OSN1800设备LDX对接S9706交换机,交换机持续有CRC错误告警...
  19. 随笔之与潇哥交谈1h12min内容//2021-1-28【最后一个寒假作业】
  20. 南通大学机械院两年来的心得体会(给大一新生的一点建议)

热门文章

  1. 985、211学校分为哪八个档次?
  2. 【部署加速】模型Int8量化
  3. 2019最新迅为-i.MX6Q开发板资料目录
  4. C语言四种方法求最大公约数
  5. B75对应的服务器芯片组,技嘉GA-B75M-D3V的主板架构是什么
  6. Win10下E3-1231 V3开启Intel虚拟化技术(vt-x)安装HAXM
  7. 石头机器人红灯快闪_机器人演绎科技快闪 人机“舞林大会”燃动西安高新区...
  8. dedecms如何自定义分页样式
  9. 如何使用ipv6格式的url访问HTTP服务器
  10. MCS-51单片机的定时器/计数器