一.Threading模块
1.概述:threading模块是python中用来创建和管理线程的模块,还提供了一系列用于线程同步与线程间通信的方法与对象。
2.threading模块的对象:
1). Thread:表示一个执行线程的对象。
2). Lock:锁原语对象。
3). RLock:可重入锁对象。
4). Condition:条件变量对象,使得一个线程等待另一个线程满足的特点“条件”,比如改变状态或某个数据。
5). Event:条件变量的通用版本,任意数量的线程等待某个事件的发生,在该事件发生后所有的线程将被激活。
6). Semaphore:为线程间共享的有限资源提供一个“计数器”,如果没有可用资源则会被阻塞。
7). BoundedSemaphore:与Semaphore相似,不过它不允许超过初始值。
8). Timer:与Thread(threading的相对更底层,相对更低级的版本)相似,不过它在运行前要等待一定时间。
9). Barrier:创建一个“障碍”,必须达到指定数量的线程后才可以继续。
3.Thread类
1). Thread类的基本属性:
属性 描述
name 线程名
ident 线程的标示符
daemon 布尔标志, 表示是否为守护线程
2). Thread类的基本方法:
方法 描述
start() 开始执行线程
run() 定义线程功能的方法(通常在子类中被重写)
join(timeout = None) 直至启动的线程终止前一直被挂起,除非时间超过给出的timeou(秒),否则一直阻塞
getName() 返回线程名
setName() 设置线程名
Is_alive() 判断线程是否存活
3). Thread的构造方法:
a. 函数原形: threading.Thread.__init__(target = None, name = None, args = (), kwargs = {}, verbose = None, daemon = None)
b.参数解释:target为调用对象, name为线程名, args与kwargs为函数的参数,daemon标志是否为守护进程。
下面的例子说明一下join()的用法:
from threading import Thread
from time import time, sleep
def fun1():
for i in range(5):
print(i)
sleep(2)
def fun2():
for i in "abcde":
print(i)
sleep(2)
fun = [fun1, fun2]
ths = []
def main1():
for f in fun:
th = Thread(target = f)
ths.append(th)
th.start()
for i in ths: #这里join()不能放到循环里,不然就多线程和单线程就没区别了
i.join()
for i in "ABCDE":
print(i)
sleep(2)
if __name__ == "__main__":
main1()
代码执行结果为:
0
a
1
b
2
c
3
d
4
e
A
B
C
D
E
两个子线程的代码运行结束之后,主线程的代码才继续运行
——————————————————————————————————————————————————————————
再看看没有join()的时候的结果,即把上面的代码去掉join的那个循环
0
a
A
1
b
B
2
c
C
3
d
D
4
e
E
此时一个数字,一个小写字母,一个大写字母一起出现,表明两个子进程与一个主进程在同时独立运行
————————————————————————————————————————————————————————————————
再看看设置了守护进程标志后的情况,即把th = Thread(target = f)改为th = Thread(target = f, deamon = True)
结果为:
0
a
A
B
C
D
E
可以看到主线程并没有等待两个子线程运行结束就自己结束了,而主线程一结束,子线程也自然跟着终止了。