Python 多线程 Thread(二):Thread 类的几种方法

threading 的 Thread 类内置了如下几种方法及属性

属性/函数 描述 start() 一个Thread对象只能调用一次start(),重复调用会引发RuntimeError的错误,其本质是在一个单独线程中调用run()函数。 run() 要运行的部分 join(timeout=None) 等待线程终止返回None,如果设置了timeout,当超时后,返回None。若在线程启动之前调用,会引发RuntimeError的错误。 name 单纯的字符串,默认名称由函数设置,多个线程可重名。 getName() 返回name setName() 设置name ident 线程标识符,其值没有实际含义,主要是用作 magic cookie,比如作为含有线程相关数据的字典的索引。 is_alive() 返回布尔值,True在运行,False不在。 daemon 守护进程,默认否 isDaemon() 返回布尔值,True是,False不是 setDaemon()

这里主要讲下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()
经验分享 程序员 微信小程序 职场和发展