时间:2020-07-30 python教程 查看: 948
本文实例讲述了Python多线程Threading、子线程与守护线程。分享给大家供大家参考,具体如下:
补充:IO需要CPU吗?知乎:https://www.zhihu.com/question/27734728
python中多线程需要使用threading模块
1.直接调用threading的Thread类:
线程的创建:线程对象=thread.Thread(target=函数名,args=(参数))【补充,由于args是一个元组,单个参数时要加“,”】
线程的启动:线程对象.start(),调用start(),那么线程对象会自动去调用thread.Thread中的run()
让主线程等待其余线程结束:线程对象.join(),加了join之后,相当于阻塞了主线程,主线程只有当join的线程结束后才会向下执行
import threading,time
def run(n):
time.sleep(1)
print("task ",n)
t1=threading.Thread(target=run,args=("t1",))
t2 = threading.Thread(target=run,args=("t2",))
start_time=time.time()#开始时间
t1.start()
t2.start()
##因为是独立线程,如果想要主线程等待其他线程运行完毕,需要使用join
t1.join()
t2.join()
spend_time=time.time()-start_time
print(spend_time)##1.0多,说明是并行的结果
附加说明--join是阻塞等待:
import threading,time
class MyTread(threading.Thread):
def __init__(self,name):
super(MyTread,self).__init__()#调用父类的__init__()
self.name=name
def run(self):#重写方法,按自己的要求去写
time.sleep(1)
print("run in task",self.name,threading.current_thread(),threading.active_count())
t1=MyTread("t1")
t2=MyTread("t2")
start_time=time.time()
t1.start()
t2.start()
t1.join()
t2.join()
time.sleep(1)###主线程等待其余线程结束
print(time.time()-start_time)
#结果是2.0多,证明是join是相当于阻塞了主线程的执行,只有当线程结束后才会向下执行
2.继承threading的Thread类:
继承threading的Thread类的类要主要做两件事:
1.如果不做自定义变量的初始化,那么可以直接使用继承的父类的__init__(),如果需要做自定义变量的初始化,则需要先调用父类的__init__()【否则需要自己填写线程初始化相关的参数】
2.重写run,虽然继承了父类的run,但实际上如果不重写,那么我们继承threading的Thread类又有什么意义呢?为什么不直接调用threading的Thread类
import threading,time
class MyTread(threading.Thread):
def __init__(self,name):
super(MyTread,self).__init__()#调用父类的__init__()
self.name=name
def run(self):#重写方法,按自己的要求去写
time.sleep(1)
print("run in task",self.name,threading.current_thread(),threading.active_count())
t1=MyTread("t1")
t2=MyTread("t2")
start_time=time.time()
t1.start()
t2.start()
###主线程等待其余线程结束
t1.join()
t2.join()
print(time.time()-start_time)#结果是1.0多,证明是并行的
返回当前正在运行的线程对象
python <img title="image" border="0" alt="image" width="463" height="159" >
返回当前进程中的存活的线程对象数
get_ident():获取当前线程ID。
下面的代码显示了主线程并不会等待其守护线程结束:
import threading,time
class MyTread(threading.Thread):
def __init__(self,name):
super(MyTread,self).__init__()
self.name=name
def run(self):
print("守护线程已经启动",self.name)
time.sleep(1)
print("run in task",self.name,threading.current_thread(),threading.active_count())
t1=MyTread("t1")
t1.setDaemon(True)
t2=MyTread("t2")
t2.setDaemon(True)
start_time=time.time()#开始时间
t1.start()
t2.start()
spend_time=time.time()-start_time
print(spend_time)##0.0多,而且三个线程都执行完毕了,说明这个是并行的等待
让主线程sleep一下,显示一下如果主线程要等待守护线程,那么是并行的等待:
import threading,time
class MyTread(threading.Thread):
def __init__(self,name):
super(MyTread,self).__init__()
self.name=name
def run(self):
print("守护线程已经启动",self.name)
time.sleep(1)
print("run in task",self.name,threading.current_thread(),threading.active_count())
t1=MyTread("t1")
t1.setDaemon(True)
t2=MyTread("t2")
t2.setDaemon(True)
start_time=time.time()#开始时间
t1.start()
t2.start()
time.sleep(2)
spend_time=time.time()-start_time
print(spend_time)##2.0多,而且三个线程都执行完毕了,说明这个是并行的等待
希望本文所述对大家Python程序设计有所帮助。