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()
上一篇:
通过多线程提高代码的执行效率例子