当前位置：网站首页 > 热门文章 > 正文

python 线程之三:线程间通信，由锁实现的模块，推荐两种

bigegpt 2024-12-19 11:31 4 浏览

前面详细讲了线程锁，如果了解详细，请点击【线程锁-线程安全通信的基础】

线程间通信：

因为有了线程锁，所以线程通信才是安全的。

线程锁和线程间通信的关系解读：

同步锁（Lock）：锁一段代码
递归锁（RLock）：嵌套锁几段代码
条件变量（Condition）：锁的基础上，加入等待和唤醒，默认RLock
信号量：（Semaphore）通过条件变量来实现（自带锁），线程数量的限制
事件对象（Event）：通过条件变量来实现（自带锁），改变一个标识的真假
队列对象（queue）：通过条件变量来实现（自带锁），队列的存入和取出

线程间通信建议：

共享事件对象，传递真假。自动带锁。推荐
共享队列对象，传递消息，自动带锁。推荐
共享全局变量，传递消息。手动加锁。不推荐
共享条件变量，传递消息。手动加锁。不推荐

1、事件对象：自动带锁，管理一个线程内部标志

事件对象方法

from threading import Event  # 这个事件比较简单，就是一个标识

event = Event()  # 定义一个事件对象，
event.is_set()  # 返回：False  解读：返回内部标识，这个标识初始时为 false
event.set()   # 把内部标识设置为 True
event.clear()  # 把内部标识设置为 False
event.wait()  # 阻塞线程，直到内部标识变成 True。可以设置超时

事件对象，示例一

事件对象，示例二

2、队列对象：自动带锁，数据传递

内容较多，只说常用方法，以后再详细讲解

队列对象方法

from queue import Queue
que = Queue()  # 定义一个队列对象
que.empty()  # 为空返回 True；不为空返回 False
que.put('消息数据')  # 从队列中存入消息数据
que.get()  # 从队列中取出消息

队列对象，示例

3、共享全局变量，手动加锁

全局变量，示例

4、共享条件变量，手动加锁

条件变量，示例

# 解释一下上面程序：
"""
1、定义一个锁 con = Condition()，这个锁在两个线程中共享，只能一个线程运行
2、先启动 thd1.start()，再启动 thd2.start()
3、生产者线程先获得con锁，消费者线程遇到con锁，只能等待
4、生产者在 con 锁内，循环3次，满足 if num == 3: 的条件
5、用 con.notify() 唤醒其他线程（消费者线程）
6、用 con.wait() 释放锁，并挂起当前线程（生产者线程）

7、消费者线程 获得 con 锁，循环 3 次，满足 if num == 0: 的条件
8、用 con.notify() 唤醒其他线程（生产者线程）
9、用 con.wait() 释放锁，并挂起当前线程（消费者线程）

再进行 4、5、6、7、8、9 步骤，反复用一个锁控制线程的唤醒和挂起
"""

python守护线程

上一篇：难懂，误点!将多线程技术应用于Python的异步事件循环
下一篇：Python并发编程:化繁为简，通过线程池轻松实现多线程编程

python 线程之三:线程间通信，由锁实现的模块，推荐两种

相关推荐

idea本地配置连接远程hadoop集群的一些网络问题解决汇总

无缓存不行?例行升级的入门级阿斯加特AN2 SSD装机点评

Ceph运维手册(基于P版本)

大数据开发前要做什么准备?8台Hadoop服务器进行集群规划前配置

Tensorflow分类loss函数总结 tensorflow绘制loss曲线

R语言学习笔记(七) -离散型数据的模型预测2

iOS Runtime详解

7 个对 Java 意义重大的性能指标，你知道几个?

PHP 远程调试最佳实践

Laravel框架使用图片处理简单教程