Python 多线程之threading 模块的使用
作者:HLee 发布时间:2022-09-01 23:53:27
目录
简介
创建线程
构造器方式
继承方式
守护线程
线程本地数据
定时器
简介
Python 通过 _thread 和 threading 模块提供了对多线程的支持,threading 模块兼具了 _thread 模块的现有功能,又扩展了一些新的功能,具有十分丰富的线程操作功能
创建线程
使用 threading 模块创建线程通常有两种方式:
1)使用 threading 模块中 Thread 类的构造器创建线程,即直接对类 threading.Thread 进行实例化,并调用实例化对象的 start 方法创建线程;
2)继承 threading 模块中的 Thread 类创建线程类,即用 threading.Thread 派生出一个新的子类,将新建类实例化,并调用其 start 方法创建线程。
构造器方式
调用 threading.Thread 类的如下构造器创建线程:
threading.Thread(group=None, target=None, name=None, args=(), kwargs={}, *, daemon=None)
group:指定该线程所属的线程组,目前该参数还未实现,为了日后扩展 ThreadGroup 类实现而保留。
target:用于 run() 方法调用的可调用对象,默认是 None,表示不需要调用任何方法。
args:是用于调用目标函数的参数元组,默认是 ()。
kwargs:是用于调用目标函数的关键字参数字典,默认是 {}。
daemon:如果 daemon 不是 None,线程将被显式的设置为守护模式,不管该线程是否是守护模式,如果是 None (默认值),线程将继承当前线程的守护模式属性。
import time
import threading
def work(num):
print('线程名称:',threading.current_thread().getName(),'参数:',num,'开始时间:',time.strftime('%Y-%m-%d %H:%M:%S'))
if __name__ == '__main__':
print('主线程开始时间:',time.strftime('%Y-%m-%d %H:%M:%S'))
t1 = threading.Thread(target=work,args=(3,))
t2 = threading.Thread(target=work,args=(2,))
t3 = threading.Thread(target=work,args=(1,))
t1.start()
t2.start()
t3.start()
t1.join()
t2.join()
t3.join()
print('主线程结束时间:', time.strftime('%Y-%m-%d %H:%M:%S'))
上述示例中实例化了三个 Thread 类的实例,并向任务函数传递不同的参数,start
方法开启线程,join
方法阻塞主线程,等待当前线程运行结束。
继承方式
通过继承的方式创建线程包括如下步骤:1)定义 Thread 类的子类,并重写该类的 run 方法;2)创建 Thread 子类的实例,即创建线程对象;3)调用线程对象的 start 方法来启动线程。示例如下:
import time
import threading
class MyThread(threading.Thread):
def __init__(self,num):
super().__init__()
self.num = num
def run(self):
print('线程名称:', threading.current_thread().getName(), '参数:', self.num, '开始时间:', time.strftime('%Y-%m-%d %H:%M:%S'))
if __name__ == '__main__':
print('主线程开始时间:',time.strftime('%Y-%m-%d %H:%M:%S'))
t1 = MyThread(3)
t2 = MyThread(2)
t3 = MyThread(1)
t1.start()
t2.start()
t3.start()
t1.join()
t2.join()
t3.join()
print('主线程结束时间:', time.strftime('%Y-%m-%d %H:%M:%S'))
上述示例中自定义了线程类 MyThread,继承了 threading.Thread,并重写了 __init__ 方法和 run 方法。
守护线程
守护线程(也称后台线程)是在后台运行的,它的任务是为其他线程提供服务,如 Python 解释器的垃圾回收线程就是守护线程。如果所有的前台线程都死亡了,守护线程也会自动死亡。来看个例子:
# 不设置守护线程
import threading
def work(num):
for i in range(num):
print(threading.current_thread().name + " " + str(i))
t = threading.Thread(target=work, args=(10,), name='守护线程')
t.start()
for i in range(10):
pass
# 设置守护线程
import threading
def work(num):
for i in range(num):
print(threading.current_thread().name + " " + str(i))
t = threading.Thread(target=work, args=(10,), name='守护线程')
t.daemon = True
t.start()
for i in range(10):
pass
上述示例直观的说明了当前台线程结束,守护线程也会自动结束。
如果你设置一个线程为守护线程,就表示这个线程是不重要的,在进程退出的时候,不用等待这个线程退出;如果你的主线程在退出的时候,不用等待哪些子线程完成,那就设置这些线程为守护线程;如果你想等待子线程完成后再退出,那就什么都不用做,或者显示地将 daemon 属性设置为 false。
线程本地数据
Python 的 threading 模块提供了 local 方法,该方法返回得到一个全局对象,不同线程使用这个对象存储的数据,其它线程是不可见的(本质上就是不同的线程使用这个对象时为其创建一个独立的字典)。来看个示例:
# 不使用 threading.local
import threading
import time
num = 0
def work():
global num
for i in range(10):
num += 1
print(threading.current_thread().getName(), num)
time.sleep(0.0001)
for i in range(5):
threading.Thread(target=work).start()
上面示例中 num 是全局变量,变成了公共资源,通过输出结果,我们发现子线程之间的计算结果出现了互相干扰的情况。
# 使用 threading.local
num = threading.local()
def work():
num.x = 0
for i in range(10):
num.x += 1
print(threading.current_thread().getName(), num.x)
time.sleep(0.0001)
for i in range(5):
threading.Thread(target=work).start()
使用 threading.local 的示例中,num 是全局变量,但每个线程定义的属性 num.x 是各自线程独有的,其它线程是不可见的,因此每个线程的计算结果未出现相互干扰的情况。
定时器
threading 模块提供了 Timer 类实现定时器功能,来看个例子:
# 单次执行
from threading import Timer
def work():
print("Hello Python")
# 5 秒后执行 work 方法
t = Timer(5, work)
t.start()
Timer 只能控制函数在指定的时间内执行一次,如果我们需要多次重复执行,需要再进行一次调度,想要取消调度时可以使用 Timer 的 cancel 方法。来看个例子:
# 重复执行
count = 0
def work():
print('当前时间:', time.strftime('%Y-%m-%d %H:%M:%S'))
global t, count
count += 1
# 如果 count 小于 5,开始下一次调度
if count < 5:
t = Timer(1, work)
t.start()
# 指定 2 秒后执行 work 方法
t = Timer(2, work)
t.start()
来源:https://cloud.tencent.com/developer/article/1810971
猜你喜欢
- 大家好,使用 Python Flask 创建 URL 缩短器是一个有趣而简单的项目,可以帮助您深入了解 Web 开发的世界。Flask 是
- 一、前言我们在使用pycharm写代码时可能出现过下面这种情况,不小心点到了ignore ....:这样会导致整个代码都没有错误提示了,类似
- 背景:作为一个python小白,今天从菜鸟教程上看了一些python的教程,看到了python的一些语法,对比起来(有其他语言功底),感觉还
- 单位的小王学习SQL Server已有一段时间了,已经做了个不错的管理系统,有次小王让我帮着看看库的设计有没有问题,其间我发现他的安全意识非
- 从技术上来说,在ASP环境中,读入并管理XML文本的主要方法有三种: 创建MSXML对象,并且将XML文档载入DOM; 使用服务器端嵌入(S
- 在迭代中enumerate比range更能灵活,一般情况下尽量用erumerate,下面举例说明:先来看range的使用:city_list
- PHP mysqli_rollback() 函数关闭自动提交,做一些查询,提交查询,然后回滚当前事务:<?php// 假定数据库用户名
- 一、摘要Python使用被称为异常 的特殊对象来管理程序执行期间发生的错误。每当发生让Python不知所措的错误时,它都会创建一个异常对象。
- 前言最近又多了不少朋友关注,先在这里谢谢大家。关注我的朋友大多数都是大学生,而且我简单看了一下,低年级的大学生居多,大多数都是为了完成课程设
- 本文实例讲述了python中for语句简单遍历数据的方法。分享给大家供大家参考。具体如下:for name in ["kak&qu
- Mac 环境中既有自带的 Python2.7 也有自己安装的 Python 3.5.1,默认想用 Python3 的环境1. 添加 Pyth
- Howdy, 大家好,又是我~ 上一次我们简单的谈了一下font set和一些要注意的基本问题。今天我们继续字体这一话题,深入讲讲上次提到
- Entity Framework 4.0 也可以支持大名鼎鼎的MySql,这篇POST将向展示如何实现EF+MyS
- Dmitry这篇设计评论表单很有启发意义,尤其提到关键的评论内容、评论者信息录入顺序问题。好比我们在日常沟通时,对信息的反馈都是第一诉求,写
- 找了国内30个比较著名的网站的注册表单做样本,对标签和输入区对齐方式做了统计,得到了一个结论:标签水平右对齐更适合中文网站,或者说右对齐更适
- <% Function XMLEncode(byVal sText) sText = Replace(sText, "&am
- 目录代码分享一、安装并创建Scrapy项目二、爬取应用市场评论过程1. Scrapy爬虫运行流程2. 页面分析页面分析过程一页面分析过程二页
- 内容摘要:ASP开发人员为了在他们的设计项目中获得更好的性能和可扩展性而不断努力。幸运地是,有许多书籍和站点在这方面提供了很好的建议。但是这
- 水平线对于制作网页的朋友来说一定不会陌生,它在网页的版式设计中是非常有作用的,可以用来分隔文本和对象。
- Delphi连接MySQL真麻烦,研究了一天,从网上找了无数文章,下载了无数插件都没解决。最后返璞归真,老老实实用ADO来连接,发现也不是很