Python Event实现线程通信
Event 是一种非常简单的线程通信机制,一个线程发出一个 Event,另一个线程可通过该 Event 被触发。
Event 本身管理一个内部旗标,程序可以通过 Event 的 set() 方法将该旗标设置为 True,也可以调用 clear() 方法将该旗标设置为 False。程序可以调用 wait() 方法来阻塞当前线程,直到 Event 的内部旗标被设置为 True。
Event 提供了如下方法:
下面程序示范了 Event 最简单的用法:
直到主程序执行到最后一行,程序调用了 Event 的 set() 方法将 Event 的内部旗标设直为 True,并唤醒所有等待的线程,这两个线程才能向下执行。
运行上面程序,将看到如下输出结果:
Event 本身管理一个内部旗标,程序可以通过 Event 的 set() 方法将该旗标设置为 True,也可以调用 clear() 方法将该旗标设置为 False。程序可以调用 wait() 方法来阻塞当前线程,直到 Event 的内部旗标被设置为 True。
Event 提供了如下方法:
- is_set():该方法返回 Event 的内部旗标是否为True。
- set():该方法将会把 Event 的内部旗标设置为 True,并唤醒所有处于等待状态的线程。
- clear():该方法将 Event 的内部旗标设置为 False,通常接下来会调用 wait() 方法来阻塞当前线程。
- wait(timeout=None):该方法会阻塞当前线程。
下面程序示范了 Event 最简单的用法:
import threading import time event = threading.Event() def cal(name): # 等待事件,进入等待阻塞状态 print('%s 启动' % threading.currentThread().getName()) print('%s 准备开始计算状态' % name) event.wait() # ① # 收到事件后进入运行状态 print('%s 收到通知了.' % threading.currentThread().getName()) print('%s 正式开始计算!'% name) # 创建并启动两条,它们都会①号代码处等待 threading.Thread(target=cal, args=('甲', )).start() threading.Thread(target=cal, args=("乙", )).start() time.sleep(2) #② print('------------------') # 发出事件 print('主线程发出事件') event.set()上面程序以 cal() 函数为 target,创建并启动了两个线程。由于 cal() 函数在 ① 号代码处调用了 Event 的 wait(),因此两个线程执行到 ① 号代码处都会进入阻塞状态;即使主线程在 ② 号代码处被阻塞,两个子线程也不会向下执行。
直到主程序执行到最后一行,程序调用了 Event 的 set() 方法将 Event 的内部旗标设直为 True,并唤醒所有等待的线程,这两个线程才能向下执行。
运行上面程序,将看到如下输出结果:
Thread-1 启动
甲 准备开始计算状态
Thread-2 启动
乙 准备开始计算状态
------------------
主线程发出事件
Thread-1 收到通知了.
Thread-2 收到通知了.
甲 正式开始计算!
乙 正式开始计算!
Event 实际上优点类似于 Condition 和旗标的结合体,但 Event 本身并不带 Lock 对象,因此如果要实现线程同步,还需要额外的 Lock 对象。
下面是使用 Event 改写后的 Account:import threading class Account: # 定义构造器 def __init__(self, account_no, balance): # 封装账户编号、账户余额的两个成员变量 self.account_no = account_no self._balance = balance self.lock = threading.Lock() self.event = threading.Event() # 因为账户余额不允许随便修改,所以只为self._balance提供getter方法 def getBalance(self): return self._balance # 提供一个线程安全的draw()方法来完成取钱操作 def draw(self, draw_amount): # 加锁 self.lock.acquire() # 如果Event内部旗标为True,表明账户中已有人存钱进去 if self.event.is_set(): # 执行取钱操作 print(threading.current_thread().name + " 取钱:" + str(draw_amount)) self._balance -= draw_amount print("账户余额为:" + str(self._balance)) # 将Event内部旗标设为False self.event.clear() # 释放加锁 self.lock.release() # 阻塞当前线程阻塞 self.event.wait() else: # 释放加锁 self.lock.release() # 阻塞当前线程阻塞 self.event.wait() def deposit(self, deposit_amount): # 加锁 self.lock.acquire() # 如果Event内部旗标为False,表明账户中还没有人存钱进去 if not self.event.is_set(): # 执行存款操作 print(threading.current_thread().name\ + " 存款:" + str(deposit_amount)) self._balance += deposit_amount print("账户余额为:" + str(self._balance)) # 将Event内部旗标设为True self.event.set() # 释放加锁 self.lock.release() # 阻塞当前线程阻塞 self.event.wait() else: # 释放加锁 self.lock.release() # 阻塞当前线程阻塞 self.event.wait()
所有教程
- socket
- Python基础教程
- C#教程
- MySQL函数
- MySQL
- C语言入门
- C语言专题
- C语言编译器
- C语言编程实例
- GCC编译器
- 数据结构
- C语言项目案例
- C++教程
- OpenCV
- Qt教程
- Unity 3D教程
- UE4
- STL
- Redis
- Android教程
- JavaScript
- PHP
- Mybatis
- Spring Cloud
- Maven
- vi命令
- Spring Boot
- Spring MVC
- Hibernate
- Linux
- Linux命令
- Shell脚本
- Java教程
- 设计模式
- Spring
- Servlet
- Struts2
- Java Swing
- JSP教程
- CSS教程
- TensorFlow
- 区块链
- Go语言教程
- Docker
- 编程笔记
- 资源下载
- 关于我们
- 汇编语言
- 大数据
- 云计算
- VIP视频