python 多线程threading程序详情_Python

python 多线程threading程序详情

2022-11-29 11:09WX_LW Python

这篇文章主要介绍了python 多线程threading程序详情，Thread类表示在单独的控制线程中运行的活动，下文相关资料需要的小伙伴可以参考一下

CPython implementation detail: 在 CPython 中，由于存在全局解释器锁，同一时刻只有一个线程可以执行 Python 代码（虽然某些性能导向的库可能会去除此限制）。如果你想让你的应用更好地利用多核心计算机的计算资源，推荐你使用multiprocessing或concurrent.futures.ProcessPoolExecutor但是，如果你想要同时运行多个 I/O 密集型任务，则多线程仍然是一个合适的模型。

再来引入一个概念：

并行（parallelism）： 是同一时刻，每个线程都在执行。
并发（concurrency）：是同一时刻，只有一个线程执行，然后交替执行(再加上电脑运行速度快)。所以从一个宏观的角度来看，似乎每个线程都在执行了。

可以知道python线程是并发的。

关于线程Threading的方法（获取线程的某种属性）。

active_count()：它会获得，执行这个方法时，还存活的Thread()的对象数量。
enumerate()：返回当前所有存活的Thread对象的列表。
current_thread()：返回当前调用者控制Thread()线程的对象。如果调用者控制的线程对象不是由threading创建，则会返回一个功能受限的虚拟线程对象。
get_ident()：返回当前线程的“线程标识符”。它是一个非零整数。
get_native_id()：返回内核分配给当前线程的原生集成线程ID。这是一个非负整数。
main_thread()：返回主线程(thread)对象，一般是python解释器开始时创建的线程。

线程简介：

　Thread类表示在单独的控制线程中运行的活动。指定活动有两种方法：将可调用对象传递给构造函数，或重写子类中的run（）方法。子类中不应重写任何其他方法（构造函数除外）。换句话说，只重写这个类的_init__;（）和run（）方法

一旦线程活动开始，该线程会被认为是 '存活的' 。当它的run() 方法终结了（不管是正常的还是抛出未被处理的异常），就不是'存活的'。

先看看该类的参数有哪些：

class threading.Thread(group=None, target=None, name=None, args=(), kwargs={}, *, daemon=None)

group：官方的解释是，为了日后扩展ThreadGroup类实现而保留。(唉，我也不太清楚的)
target：是要于多线程的函数
name：是线程的名字
args ：函数的参数，类型是元组()
kwargs：函数的参数，类型是字典{}

为了便于理解，先举一个小例子，为了方便理解，先简单了解一下该类的一个方法（函数在类中被称为方法）：

start()：开始线程活动

				?

									import threading

									import time

									# 打印函数a

									def printa(a):

									    count = 0

									    while count < 5:

									        time.sleep(2)

									        print("线程：%s。打印：%s。时间：%s。" % (threading.current_thread().name, a, time.ctime()))

									        count += 1

									# 打印函数b

									def printb(b):

									    count = 0

									    while count < 5:

									        time.sleep(4)

									        print("线程：%s。打印：%s。时间：%s。" % (threading.current_thread().name, b, time.ctime()))

									        count += 1

									# threading.Thread(target=,args=(),name='')

									t1 = threading.Thread(target=printa, args=(10,), name='线程1')

									t2 = threading.Thread(target=printb, args=(20,), name='线程2')

									t1.start()

									t2.start()

									t1.join()

									t2.join()

									print("退出主线程")

				?

									import threading

									import time

									# 打印函数a

									def printa(a):

									    count = 0

									    while count < 5:

									        time.sleep(2)

									        print("线程：%s。打印：%s。时间：%s。" % (threading.current_thread().name, a, time.ctime()))

									        count += 1

									# threading.Thread(target=,args=(),name='')

									threadList = []

									for i in range(3):

									    t = threading.Thread(target=printa, args=(i,))

									    threadList.append(t)

									for t in threadList:

									    t.start()

									for t in threadList:

									    t.join()

									print("退出主线程")