焦作焦煤电子商务网站建设,那个大学业做网站,分析苏宁易购的网站建设,网站建设资源平台参考#xff1a;《Python核心编程》 threading 模块的Thread 类是主要的执行对象#xff0c;而且#xff0c;使用Thread类可以有很多方法来创建线程#xff0c;这里介绍以下两种方法#xff1a;
创建 Thread 实例#xff0c;传给它一个函数。派生 Thread 的子类#xf…参考《Python核心编程》 threading 模块的Thread 类是主要的执行对象而且使用Thread类可以有很多方法来创建线程这里介绍以下两种方法
创建 Thread 实例传给它一个函数。派生 Thread 的子类并创建子类的实例。
如果是有面向对象接口需求的第二种方法更加符合。
1、创建Thread的实例传给它一个函数
示例代码:
from threading import Thread
from time import sleep, ctimeloops [4, 2]def loop(nloop, nsec):print(start loop , nloop, at , ctime())sleep(nsec)print(nloop , nloop, done at , ctime())def main():threads []print(starting at: , ctime())# create all threadsfor i in range(len(loops)):t Thread(targetloop, args(i, loops[i]))threads.append(t)# start threadfor i in range(len(loops)):threads[i].start()# wait for all threads to finishfor i in range(len(loops)):threads[i].join()print(all DONE at: , ctime())if __name__ __main__:main()
执行脚本
$ python myThread.py
starting at: Sat Jan 20 17:22:28 2024
start loop 0 at Sat Jan 20 17:22:28 2024
start loop 1 at Sat Jan 20 17:22:28 2024
nloop 1 done at Sat Jan 20 17:22:30 2024
nloop 0 done at Sat Jan 20 17:22:32 2024
all DONE at: Sat Jan 20 17:22:32 2024在上述代码中当实例化每个 Thread 对象时把函数target和参数args传进去然后得到返回的 Thread 实例。实例化 Thread 后线程不会立即开始执行而是把启动的指挥权交给程序员这是一个非常有用的同步功能尤其是当你并不希望线程开始立即执行时。 当所有线程都分配完成之后,通过调用每个线程的 start()方法让它们开始执行。 join()方法将等待当前或所有线程结束后再往下执行。一旦线程启动,它们就会一直执行,直到给定的函数完成后退出。如果主线程还有其他事情要去做,而不是等待这些线程完成(例如其他处理或者等待新的客户端请求),就可以不调用 join()。join()方法只有在你需要等待线程完成的时候才是有用的。比如如果将 join() 方法所在的 for 循环注释掉那么执行脚本后将会得到下面这样的结果
$ python myThread.py
starting at: Sat Jan 20 17:45:16 2024
start loop 0 at Sat Jan 20 17:45:16 2024
start loop 1 at Sat Jan 20 17:45:16 2024
all DONE at: Sat Jan 20 17:45:16 2024
nloop 1 done at Sat Jan 20 17:45:18 2024
nloop 0 done at Sat Jan 20 17:45:20 20242、派生 Thread 的子类并创建子类的实例
当创建线程时使用子类要相对更容易阅读而且如上所述当你需要一个更加符合面向对象的接口时, 会选择这种方法。下面的示例中将对 Thread 子类化,而不是直接对其实例化。这将使我们在定制线程对象时拥有更多的灵活性,也能够简化线程创建的调用过程。 示例代码
from threading import Thread
from time import sleep, ctimeloops [4, 2]class MyThread(Thread):def __init__(self, func, args, name):Thread.__init__(self) # 调用基类构造方法self.func funcself.args argsself.name namedef run(self):self.func(*self.args)def loop(nloop, nsec):print(start loop , nloop, at , ctime())sleep(nsec)print(loop , nloop, done at , ctime())def main():threads []# 创建线程for i in range(len(loops)):t MyThread(funcloop, args(i,loops[i]), nameloop.__name__)threads.append(t)# 启动线程for i in range(len(loops)):threads[i].start()# 等待所有线程执行完毕for i in range(len(loops)):threads[i].join()print(all DONE at , ctime())if __name__ __main__:main()
执行脚本
$ python myThread2.py
start loop 0 at Sat Jan 20 18:49:51 2024
start loop 1 at Sat Jan 20 18:49:51 2024
loop 1 done at Sat Jan 20 18:49:53 2024
loop 0 done at Sat Jan 20 18:49:55 2024
all DONE at Sat Jan 20 18:49:55 2024MyThread 子类的构造函数必须先调用其基类的构造函数。 当创建新线程时,Thread 类的代码将调用 MyThread 对象,此时会调用__run__()这个特殊方法。
补Thread 对象的属性和方法
