python中Event实现线程间同步介绍
短信预约 -IT技能 免费直播动态提醒
前言：
Event在python线程间同步是一种常用的方法，本博客以生产者线程和工作者线程为例说明Event在线程间进行10次同步的应用。
import threading
from threading import Event, Thread
import time
import random
from time import sleep
pevent = Event() #默认是没有事件的
pevent.clear()
cevent = Event()
cevent.clear()
runtimes = 10
mutex_lock = threading.Lock()
class ProducerThread (threading.Thread):
def __init__(self, name, runflag):
threading.Thread.__init__(self)
self.name = name
self.runflag = runflag
self.continueflag = Event()
self.continueflag.set()
def run(self):
global runtimes
sleep(1)
print ("开始线程：" + self.name)
while self.continueflag.isSet():
print("wait consumer ...")
if runtimes == 0:
self.continueflag.clear()
break
pevent.wait()
print("come an consumer ...")
mutex_lock.acquire()
runtimes = runtimes - 1
mutex_lock.release()
pevent.clear()
sleep(1)
cevent.set()
print ("退出线程：" + self.name)
self.runflag.set()
class ConsumerThread (threading.Thread):
def __init__(self,name, runflag):
threading.Thread.__init__(self)
self.name = name
self.runflag = runflag
self.continueflag = Event()
self.continueflag.set()
def run(self):
global runtimes
print ("开始线程：" + self.name)
while self.continueflag.isSet():
if 0 == runtimes:
self.continueflag.clear()
pevent.set()
break
print("I want to consum ... ", runtimes)
pevent.set() #通知生产者要消费
cevent.wait()
cevent.clear()
sleep(1)
print ("退出线程：" + self.name)
self.runflag.set()
def test_pthread():
runflag = Event()
pt = ProducerThread("producer", runflag)
ct = ConsumerThread("consumer", runflag)
pt.start()
ct.start()
pt.join()
ct.join()
runflag.wait()
if __name__ == '__main__':
print('===============begin=================')
test_pthread()
print('===============end=================')运行结果如下：
到此这篇关于python中Event实现线程间同步介绍的文章就介绍到这了,更多相关Event线程间同步内容请搜索编程网以前的文章或继续浏览下面的相关文章希望大家以后多多支持编程网！
免责声明：
① 本站未注明“稿件来源”的信息均来自网络整理。其文字、图片和音视频稿件的所属权归原作者所有。本站收集整理出于非商业性的教育和科研之目的，并不意味着本站赞同其观点或证实其内容的真实性。仅作为临时的测试数据，供内部测试之用。本站并未授权任何人以任何方式主动获取本站任何信息。
② 本站未注明“稿件来源”的临时测试数据将在测试完成后最终做删除处理。有问题或投稿请发送至: 邮箱/279061341@qq.com QQ/279061341
