Python菜鸟教程:线程管理
线程管理主要包括线程创建、启动、休眠、等待线程结束和线程停止,线程创建即为我们上一节学习的内容,线程启动的方式为thread.start(),线程休眠的方式为time.sleep(),注意要引入time模块才可以使用线程休眠功能,这一节我们就来学习一下等待线程结束和线程停止。
1. 等待线程结束
所谓等待线程结束,就是保证主线程在子线程结束之后结束,使用的依然是join()方法,我们需要在join中设置超时时间,即join(timeout = None)。
代码如下:
1234567891011121314 | import threading
import time
def test():
print
(
'子线程开始'
)
for i
in range
(
3
):
print
(
'第%d次执行子线程'
%
i)
time.sleep(
1
)
print
(
'子线程结束'
)
if __name__
=
= '__main__'
:
print
(
'主线程开始'
)
thread_one
= threading.Thread(target
=
test)
thread_one.start()
thread_one.join()
#如果注释掉再看一下运行结果
print
(
'主线程结束'
) |
运行结果如下:
1234567 | 主线程开始
子线程开始
第
次执行子线程
第
1
次执行子线程
第
2
次执行子线程
子线程结束
主线程结束 |
把代码倒数第二行的等待线程结束注释掉,运行结果为:
1234567 | 主线程开始
子线程开始
第
次执行子线程
主线程结束
第
1
次执行子线程
第
2
次执行子线程
子线程结束 |
运行结果会出现子线程还没有结束,主线程就已经结束的情况,所以我们增加等待线程结束的语句能保障程序的运行。
2. 线程停止
我们在创建线程之后,如果run()方法或者函数执行结束,那么线程就会停止,但是当我们遇到一些限制条件的时候,例如我们当前的内存不支持过多的线程运行,因此当线程数量超过规定数的时候,我们就要把线程停止,或者我们规定的时间到了之后我们就需要把线程停止。
线程停止的方法我们可以采用设置一个线程停止变量,代码如下:
1234567891011121314 | import time
import threading
running
= True
def test():
while running:
print
(
'线程开始工作\n'
)
time.sleep(
8
)
print
(
'工作完毕'
)
if __name__
=
= '__main__'
:
thread
= threading.Thread(target
= test)
thread.start()
s
= input
(
'是否停止执行,确认停止请输入False:'
)
if s
=
= 'False'
:
running
= False |
运行结果如下:
123 | 线程开始工作
是否停止执行,确认停止请输入
False
:
False
工作完毕 |
在这里,我们首先是创建了一个使线程停止的变量,然后我们在函数体中进行一个判断,如果这个变量为True就执行相关工作,除了这个变量我们没有设置停止操作,因此只要这个变量不改变,那么工作完毕这条语句是不会被执行的,那么我们在主程序中先创建一个线程来使用这个方法,然后我们可以通过键盘输入指令,如果我们输入的指令为Flase时,那么while中的判断即为False,因此子线程工作完毕。