python3 线程隔离_Python并发编程之线程中的信息隔离(五)
大家好,并发编程 进入第三篇。
上班第一天,大家应该比较忙吧。小明也是呢,所以今天的内容也很少。只要几分钟就能学完。
昨天我们说,线程与线程之间要通过消息通信来控制程序的执行。
讲完了消息通信,今天就来探讨下线程里的信息隔离是如何做到的。大家注意:
信息隔离,这并不是官方命名的名词,也不是网上广为流传的名词。是我为了方便理解而自创的,大家知道就好咯。
本文目录初步认识信息隔离
信息隔离的意义何在
. 初步认识信息隔离
什么是信息隔离?
比如说,咱有两个线程,线程A里的变量,和线程B里的变量值不能共享。这就是信息隔离。
你可能要说,那变量名取不一样不就好啦?
是的,如果所有的线程都不是由一个class实例化出来的同一个对象,确实是可以。这个问题我们暂且挂着,后面我再说明。
那么,如何实现信息隔离呢?
在Python中,其提供了threading.local这个类,可以很方便的控制变量的隔离,即使是同一个变量,在不同的线程中,其值也是不能共享的。
用代码来看下from threading import local, Thread, currentThread
# 定义一个local实例
local_data = local()
# 在主线中,存入name这个变量
local_data.name = 'local_data'
class MyThread(Thread):
def run(self):
print("赋值前-子线程:", currentThread(),local_data.__dict__)
# 在子线程中存入name这个变量
local_data.name = self.getName()
print("赋值后-子线程:",currentThread(), local_data.__dict__)
if __name__ == '__main__':
print("开始前-主线程:",local_data.__dict__)
t1 = MyThread()
t1.start()
t1.join()
t2 = MyThread()
t2.start()
t2.join()
print("结束后-主线程:",local_data.__dict__)
来看看输出结果开始前-主线程: {'name': 'local_data'}
赋值前-子线程: {}
赋值后-子线程: {'name': 'Thread-1'}
赋值前-子线程: {}
赋值后-子线程: {'name': 'Thread-2'}
结束后-主线程: {'name': 'local_data'}
从输出来看,我们可以知道,local实际是一个字典型的对象,其内部可以以key-value的形式存入你要做信息隔离的变量。local实例可以是全局唯一的,只有一个。因为你在给local存入或访问变量时,它会根据当前的线程的不同从不同的存储空间存入或获取。
基于此,我们可以得出以下三点结论:主线程中的变量,不会因为其是全局变量,而被子线程获取到;
主线程也不能获取到子线程中的变量;
子线程与子线程之间的变量也不能互相访问。
所以如果想在当前线程保存一个全局值,并且各自线程(包括主线程)互不干扰,使用local类吧。
. 信息隔离的意义何在
细心的你,一定已经发现了,上面那个例子,即使我们不用threading.local来做信息隔离,两个线程self.getName()本身就是隔离的,没有任何关系的。因为这两个线程是由一个class实例出的两个不同的实例对象。自然是可以不用做隔离,因为其本身就是隔离的。
但是,现实开发中。不可排除有多个线程,是由一个class实例出的同一个实例对象而实现的。
譬如,现在新手特别喜欢的爬虫项目。通常都是先给爬虫一个主页,然后获取主页下的所有链接,对这个链接再进行遍历,一直往下,直到把所有的链接都爬完,获取到我们所需的内容。
由于单线程的爬取效率实在是太低了,我们考虑使用多线程来工作。先使用socket和www.sina.con.cn建立一个TCP连接。然后在这个连接的基础上,对主页上的每个链接(我们这里只举news.sina.com.cn和blog.sina.com.cn这两个子链接做例子)创建一个线程,这样效率就高多了。友情提醒:
以下代码,若要理解,可能需要你了解下socket的网络编程相关内容。我在前几天的文章中有发布一篇相关的文章,没有基础的同学可以先去看看那篇文章。import threading
from functools import partial
from socket import socket, AF_INET, SOCK_STREAM
class LazyConnection:
def __init__(self, address, family=AF_INET, type=SOCK_STREAM):
self.address = address
self.family = AF_INET
self.type = SOCK_STREAM
self.local = threading.local()
def __enter__(self):
if hasattr(self.local, 'sock'):
raise RuntimeError('Already connected')
# 把socket连接存入local中
self.local.sock = socket(self.family, self.type)
self.local.sock.connect(self.address)
return self.local.sock
def __exit__(self, exc_ty, exc_val, tb):
self.local.sock.close()
del self.local.sock
def spider(conn, website):
with conn as s:
header = 'GET / HTTP/1.1\r\nHost: {}\r\nConnection: close\r\n\r\n'.format(website)
s.send(header.encode("utf-8"))
resp = b''.join(iter(partial(s.recv, 100000), b''))
print('Got {} bytes'.format(len(resp)))
if __name__ == '__main__':
# 建立一个TCP连接
conn = LazyConnection(('www.sina.com.cn', 80))
# 爬取两个页面
t1 = threading.Thread(target=spider, args=(conn,"news.sina.com.cn"))
t2 = threading.Thread(target=spider, args=(conn,"blog.sina.com.cn"))
t1.start()
t2.start()
t1.join()
t2.join()
输出结果Got 765 bytes
Got 513469 bytes
如果是在这种场景下,要做到线程之间的状态信息的隔离,就肯定要借助threading.local,所以threading.local的存在是有存在的意义的。其他还有很多场景是必须借助threading.local才能实现的,而这些就要靠你们在真正的业务开发中去发现咯。
python3 线程隔离_Python并发编程之线程中的信息隔离(五)相关推荐
- python 线程同步_Python并发编程-线程同步(线程安全)
Python并发编程-线程同步(线程安全) 作者:尹正杰 版权声明:原创作品,谢绝转载!否则将追究法律责任. 线程同步,线程间协调,通过某种技术,让一个线程访问某些数据时,其它线程不能访问这些数据,直 ...
- python线程唤醒_Python 并发编程(一)之线程
常用用法 t.is_alive() Python中线程会在一个单独的系统级别线程中执行(比如一个POSIX线程或者一个Windows线程) 这些线程将由操作系统来全权管理.线程一旦启动,将独立执行直到 ...
- python线程通信 消息传递_Python并发编程之线程消息通信机制/任务协调(四)
大家好,并发编程进入第四篇. 本文目录 前言 Event事件 Condition Queue队列 总结 .前言 前面我已经向大家介绍了,如何使用创建线程,启动线程.相信大家都会有这样一个想法,线程无非 ...
- c++ 线程池_JAVA并发编程:线程池ThreadPoolExecutor源码分析
前面的文章已经详细分析了线程池的工作原理及其基本应用,接下来本文将从底层源码分析一下线程池的执行过程.在看源码的时候,首先带着以下两个问题去仔细阅读.一是线程池如何保证核心线程数不会被销毁,空闲线程数 ...
- java queue 线程安全_java并发编程之线程安全方法
线程安全的实现方法,包含如下方式 一, 互斥同步 使用互斥锁的方式. 举个栗子 synchronized,最常用的同步实现方案, ReentrantLock,java并发包中工具,后续介绍. 互斥同步 ...
- java线程状态_java并发编程之线程状态
java线程中,线程状态是如何转换的呢?这一次我们一起来学习下. 线程状态: NEW: 线程创建之后,还没有启动.这时候它的状态就是NEW RUNNABLE: 正在Java虚拟机下跑任务的线程的状态. ...
- java判断线程是否wait_Java并发编程之线程间通讯(上)wait/notify机制
线程间通信 如果一个线程从头到尾执行完也不和别的线程打交道的话,那就不会有各种安全性问题了.但是协作越来越成为社会发展的大势,一个大任务拆成若干个小任务之后,各个小任务之间可能也需要相互协作最终才能执 ...
- java 线程安全list_JAVA并发编程实战-线程安全性
线程安全性: 对象的状态是指存储在状态变量(例如实例和静态域)中的数据. 对象的状态可能包括其他依赖对象的域. 例如:某个HashMap的状态不仅存储在HashMap对象本身,还存储在许多Map.En ...
- python线程池模块_Python并发编程之线程池/进程池--concurrent.futures模块
一.关于concurrent.futures模块 Python标准库为我们提供了threading和multiprocessing模块编写相应的多线程/多进程代码,但是当项目达到一定的规模,频繁创建/ ...
最新文章
- java jms消息删除_activemq的topic消息一直都会存在数据库中,为什么不会删除
- linux删除项目命令,项目2 Linux基本命令
- mysql没法修改数据_MySQL学习笔记之数据的增、删、改实现方法
- muduo网络库学习(一)对io复用的封装Poller,面向对象与基于对象
- 【CSU - 1023】【HRBUST - 1039】修路(二分,枚举)
- 刷抖音看到 Python 工程师的工资条后,我沉默了...
- 提供基于transformer的pipeline、准确率达SOTA
- mysql怎么添加默认约束_分享知识-快乐自己:MySQL中的约束,添加约束,删除约束,以及一些其他修饰...
- SQL Server : 使用SQL Express的User Instance(用户实例)特性
- uniapp开发h5应用进行微信网页授权登录获取code失败
- RF-接口自动化测试-「参数Parameters格式」
- 学习笔记1-【计算机组成原理】-【计算机科学速成课】[40集全/精校] - Crash Course Computer Science
- python输出集合中的所有子集_python列出集合中所有子集
- upupoo php,UPUPOO动态桌面下载
- 解密AI芯片的加速原理
- 用命令提示符运行java_怎么用命令提示符运行java程序?
- 不再年轻的我,终于读懂了成年人的世界,就没有“容易”二字
- 骑行天下之北京到天津(1)
- macOS使用C/C++万能头文件保姆级教程
- SpringBoot @RequestHeader注解接收请求头
热门文章
- 用python编程、假设一年期定期利率_python,练习题网站.doc
- 拉索检测机器人_昌都斜拉索锈蚀检测系统,斜拉索检测机器人推荐
- 记阿里的一次壮烈牺牲
- java缓冲流,BufferedReader,BufferedWriter 详解
- Spring 创建对象的问题,不同构造方法创建对象,使用工厂类类获取对象、单例或多例、延迟创建问题
- 用JavaScript获取表单里的值
- linux 更改ctime_Linux 的文件系统及文件缓存知识点整理
- vscode 调试python 无法连接远程服务器_vscode 远程调试python的方法
- python 爬虫面试题_Python爬虫面试题
- 电脑动态屏保_8款电脑软件,每一款都能让你的电脑更好用