Python 多线程 Thread(二):Thread 类的几种方法
threading 的 Thread 类内置了如下几种方法及属性
这里主要讲下join() join()这个函数只能返回None,可选的参数为超时时间,调用这个方法之后,他会阻塞主线程(调用这个方法的线程)直到返回None再执行下一个命令。那么用这个函数,你就能玩很多花样了,你可以用它判断一个线程是否在时间内完成了某项工作,是否可以开始下一项工作,是否需要终止当前进程(Thread没有自带的终止函数,你需要自己写一个。 join()函数可以理解为一个锁,对主线程来说就是一个暂停键,只有等到了返回值,才能执行下一步。
以下是个简单的示例,当线程1运行完毕后,主程序才能调用其值。
import threading
import time
class MyThread(threading.Thread):
def __init__(self,name):
threading.Thread.__init__(self,name=name)
def run(self):
self.a = 0
for i in range(10):
self.a += i
print(self.name+" "+str(self.ident)+":"+str(self.a))
time.sleep(1)
def get_a(self):
return self.a
T1=MyThread("thread 1")
T1.start()
T1.join()
print(T1.get_a())
个人理解,join()适合用于多个线程之间有依存关系的情况下,或者if else的情况,如下所示,设置超时,如果线程1在时间内计算完毕,我调用你的值,如果没有,我自行取值。
import threading
import time
class MyThread(threading.Thread):
def __init__(self,name,n=10):
threading.Thread.__init__(self,name=name)
self.n=n
def run(self):
self.a = 0
for i in range(self.n):
self.a += i
print(self.name+" "+str(self.ident)+":"+str(self.a))
time.sleep(1)
def get_a(self):
return self.a
T1=MyThread("thread 1")
T1.start()
T1.join(2)
if T1.is_alive():
T2=MyThread("thread 2",20)
T2.start()
else:
a=T1.get_a()
T2=MyThread("thread 2",a)
T2.start()
上一篇:
通过多线程提高代码的执行效率例子
