王文平的个人博客

python之线程初级

发表于 分类于 Valine：
本文字数： 2.7k 阅读时长 ≈ 2 分钟

全局解释器锁(Global Interpreter Lock)

GIL是计算机程序设计语言解释器用于同步线程的工具（解释器级别）（Cpython）GIL能够保证同一时刻只有一个线程在运行

因此python解释器同时只能执行一个线程，即使多线程的环境，也只有一个线程能获得GIL，每个线程执行一段时间后释放GIL给其他线程使用，
python的多线程只能利用cpu的一个核，GIL会在IO调用前被释放，利于IO密集型任务，（当一个线程遇到I/O任务时会释放GIL，CPU密集型线程大约执行100次解释器的计步时，会释放GIL？？这个具体没有了解）
锁是为了应对多线程的数据同步问题，同样GIL也是，但是GIL和Lock是不同的锁（后期具体分析）

如何创建一个线程

python里面的Thread类

threading.Thread(target=None,name=Node,args=(),kwargs={},*,daemon=None)
#target表示run方法将要调用的对象，就是这个新线程的目标功能函数，不带小括号，默认none是不调用任何东西
#name是线程的名字，
#args是给要调用函数的参数元组，默认（）
#kwargs是给要调用目标的关键字参数的字典，默认{}
#daemon是否是守护线程
举例：threading.Thread(target=函数名)这个方法是创建一个线程，并给这个线程分配功能

1
2
3
threads=[]#定义一个线程池
t1 = threading.Thread(target=one)#创建一个线程赋给t1，这个线程指定调用方法one，one是一个函数
threads.append(t1)#把线程t1装到线程池
三种创建线程的方法

1 创建线程实例，传给他一个函数，包括函数参数，这是常用方法，如上代码
2 创建线程实例，传给一个可调用的类实例，将调用call方法（不常用，但是更接近面向对象编程）
3 派生线程子类，创建子类的实例，必须重写run方法(必须继承threading.Thread这个父类)，这个run相当于方法1的线程函数，在start后会调用

1
2
3
4
5
6
7
8
class MyThread(Thread):
    def __init__(self, name='XX'):
        super().__init__()
        self.name = name
   
    def run(self):
    for i in range(2):
        print('XX', self.name)
线程开始运行

thread.start()，启动新线程

线程模块的基本方法

常用方法

threading.active_count()
返回当前活跃的Thread对象数量，返回值和通过enumerate（）返回的列表长度是相等（打印当前激活的线程数量，包含主线程）

threading.enumerate()
返回当前活跃的所有线程对象的列表，该列表包括守护线程，被current_thread()创建的虚拟线程对象和主线程，它不包括终止的线程和还没有启动的线程

threading.current_thread()获取当前线程，返回当前的thread对象，后面若加上.getName()则是获取当前线程名称
threading.current_thread().ident返回当前线程的id
threading.main_thread()返回主thread对象，在正常情况下，主线程是从python解释器中启动的线程
threading.getident()返回当前线程的线程标识符，线程启动后才有ID，否则为None，但是在线程退出后这个id可以再利用
thread.setName()给线程设置名称
Thread.is_alive()返回线程是否活着

退出线程

python中的线程没有优先级，不能被销毁、停止或者挂起，所以就没有恢复和中断，所以可以启动线程，但是却不能停止，线程自己在完成代码运行后会退出，或者可以调用thread.exit()可以退出，但是也不能像kill进程一样直接关闭
线程退出的两种情况：
1 线程函数内的语句执行完毕
2 线程函数中抛出未处理的异常

join函数

join函数线程阻塞，设置在start之后，等所有阻塞线程运行完，再运行主线程(主线程被停止执行)，相当于把线程加入到当前线程，等加入的线程运行完成后，再继续运行当前线程
阻塞主线程必须在start方法之后执行，t.join()等线程t运行完再运行主线程
如果想让主线程等到子线程结束后再运行，就需要用到子线程.join(),这个是在start之后，与setDaemon相反
Thread.join(timeout)这个方法有个timeout参数，是线程超时时间设置，直至启动的线程之前一直挂起，除非给出timeout时间，否则一直阻塞，阻塞当前程序，直到Thread程序运行完成，如果设置timeout就是最多阻塞多少秒，没有设置，默认永久阻塞

守护线程

_thread模块不支持守护线程，当主线程退出的时候，其他线程自动退出，不论是否在工作
threading模块支持守护线程，为子线程设置守护标记，当标记为true，thread.daemon = true，整个python程序会在所有非守护线程退出后才退出，

设置在start之前，设置子线程 A为守护线程，主线程所在的进程内所有非守护线程全部运行完毕，无论子线程A是否结束，程序都要结束
主线程退出时，不等到那些子线程完成，那么就设置子线程为守护线程，t1.setDaemon(True)，这个是设置守护线程，也可以使用thread.daemon = true这样可以检测数据合法性
如果设置一个线程为守护线程，就说明你这个线程不重要，在进程退出时，不用等待这个线程完成
如果程序不需要设置守护线程，就是等待所有子线程结束后才退出，不需要设置线程守护，或者显式调用t1.setDaemon(False)，这个是不设置守护线程
主线程是非守护线程，只要还存在一个非守护线程，程序就不会退出
一个新线程会继承父线程的守护标记

守护线程的应用场景：
1 后台任务，发送心跳包，监控
2 主线程工作才有用的线程，比如主线程中维护公共资源，主线程已经清理了，准备退出，而工作线程使用这些资源工作也没有意义，就会一起退出
3 随时可以被终止的线程
守护线程简化了程序员手动关闭线程的工作，如果主线程退出，想其他工作线程一起退出，就用守护线程创建工作线程，主线程退出，工作线程也没有必要存在，就会随着主线程的退出一起退出

休息一下，喝杯咖啡，继续创作