threading:这个模块在较低级的模块 _thread 基础上建立较高级的线程接口
以后我们就用 threading 模块来管理线程就可以了。
Tread 类:控制线程创建、启动及运行方式
一、线程的创建和启动(两种方法)
from threading import Thread
1、实例化 Thread 类的方式:
- 定义一个任务(函数或方法)
- 实例化 Thread 类,并传入函数名和参数
- start() 方法启动线程,运行传入的函数
- 任务运行完后,线程自动退出
备注说明:
start() 方法,实质是自动运行 Thread 类中 run() 方法,run() 方法去执行传入的函数
通过看源码 Thead 类的构造函数是这样的,下面做以下参数说明
def __init__(self, group=None, target=None, name=None,
args=(), kwargs=None, *, daemon=None):
group:参数保留,为了以后能加入线程组的功能,目前python没有实现线程组
target:是可调用对象,比如一个函数名
neme:线程的名称,默认情况下,threading-N
args:可调用对象的参数元组,默认()
kwargs:可调用对象的关键字参数字典,默认{}
daemon:是否为守护线程(True或者False),可以实例化时赋值
实例化 Thread 类
函数带参数的实例化
2、继承 Thread 类,重写 run() 方法的方式
- 定义一个子类,继承Thread类
- 重写run()方法(写任务)
- 实例化子类
- start() 方法启动线程,自动运行子类中的 run() 方法
- 任务运行完后,线程自动退出
备注说明:
定义的子类,只能重写 __init__() 和 run() 方法
重写 __init__() 方法时,必须初始化 Tread 类的构造函数。super(子类, self).__init__()
重写 run() 方法
重写__init__() 方法
二、线程同步和线程守护
线程同步(join()):
- 主线程遇到 thd.join() 等待子线程
- 等子线程(thd)执行结束,主线程再继续执行,直到结束
线程守护(thd.daemon = True):
- 主线程不等待子线程
- thd 跟随主线程结束
- daemon 必须在调用 start() 之前或实例化 Thread 类时设置
运行方式有四种:
1、线程同步(join):等子线程结束,主线程再继续运行
2、线程同步(join):等子线程2秒,主线程再继续运行,开始各运行各的
3、线程守护(daemon):不等子线程,跟随主线程结束
4、守护同步(daemon、join):等子线程2秒,跟随主线程结束
三、线程的其他方法
1、is_alive():返回线程是否存活(True或者False)
2、name:线程名称
设置有三种方法 是等价的
- thd = Tread(target=drink, name='drink-thread')
- thd.name='drink-thread' 常用
- thd.setName('drink-thread')
读取有两种方法 是等价的
- thd.name 常用
- thd.getName()
3、daemon:线程守护
设置 有三种方法 是等价的
- thd = Tread(target=drink, daemon=True)
- thd.daemon = True 常用
- thd.setDaemon(True)
读取 有两种方法 是等价的
- thd.daemon 常用
- thd.isDaemon()
4、ident:返回线程 id
- thd.ident
小伙伴喜欢关注哦,接下来讨论 线程锁