flask》》多线程并发数据安全问题 threading.local werkzeug.local.Local
python 作用域 问题
x=10# 全局变量deffoo():x=20# 这是局部变量,与全局 x 同名但无关print(x)# 输出 20foo()print(x)# 输出 10(全局 x 没变)本质:函数内有自己的局部命名空间,外部是全局命名空间。同名只是巧合,它们完全独立。 如果想在函数内修改全局变量,需要用global关键字。 核心目的:避免函数内部意外污染全局变量,实现代码隔离。==================================x=10# 全局变量deffoo():globalx x=20# 这是全局变量,与全局 x 同一个print(x)# 输出 20foo()print(x)# 输出 20threading.local:线程局部存储
这是多线程环境下的数据隔离机制。每个线程访问同一个 local 对象时,看到的是属于该线程自己的数据副本。
flask >>werkzeug.local.Local
协程资料
# 从 werkzeug.local 导入 Local 类(比 threading.local 功能更强,支持协程等)fromwerkzeug.localimportLocalimportthreadingimporttime# 创建一个 Local 对象,类似一个全局容器,每个线程/协程都能拥有独立的数据副本local_data=Local()defworker(worker_id):# 1. 在当前线程中设置自己的专属数据# 不同线程对同一个 local_data.user 的赋值不会互相干扰local_data.user=f"worker_{worker_id}"# 模拟一些耗时操作,让线程交错执行,验证数据隔离性time.sleep(0.1)# 2. 获取数据,验证其他线程是否干扰# 使用 getattr 避免属性不存在时报错(这里 user 一定存在,但演示安全获取方式)# getattr(object, name, default) 是 Python 内置函数,用于安全地获取对象的属性值,# 如果属性不存在则返回默认值(不会抛出 AttributeError)。# setattr(obj, 'attr', value) 等价于 obj.attr = value# hasattr(obj, 'attr') 检查属性是否存在,返回 bool# delattr(obj, 'attr') 删除属性# getattr(local_data, 'user', None) 等价 local_data.user if local_data.user else nonemy_user=getattr(local_data,'user',None)print(f"线程{worker_id}中的用户:{my_user}")threads=[]foriinrange(3):t=threading.Thread(target=worker,args=(i,))threads.append(t)t.start()fortinthreads:t.join()线程0中的用户:worker_0 线程2中的用户:worker_2 线程1中的用户:worker_1python 多线程
thread
