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

孤荷凌寒自学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