本文主要是介绍《Python多线程的初步使用》—人生苦短,我用Python(七),希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!
写在前面:
最近,博主在之前开发的网络配置自动化工具的基础上,进行了修改。将该工具改为多线程,运行效率大大提升。原本可能需要半个小时以上跑完的任务,现在只需要几十秒。
下面我们来看看是怎么实现的吧~
先看东西:
首先引入threading模块
import threading
引入之后,我们要选择,我们针对什么需求,创建多线程
在这里,因为我开发的是网络配置自动化工具;那么,我需要的是,针对每一次登录网络设备执行相关配置脚本的这一需求,创建多线程。
首先,我们创建threads变量,将它引入为列表的形式
threads=[]
创建好后,我们需要思考,我们以什么为依据创建多线程;同样,因为我们是要登录网络设备,进行配置。那么,我可以选择以有多少台网络设备、多少个IP地址等等,创建多线程。
这里我选择,以有多少个设备的IP地址,就创建多少个线程。达到同时登录多台网络设备,同时进行配置的效果。
确定需要创建多少个线程后,我们需要在之前创建的threads变量中,添加任务。
任务可以是你之前定义好的一种方法,像我这里,就是将之前开发好的登录网络设备、执行脚本的动作定义为NetmikoConfig这一方法,该方法依次需要输入的参数如下:,设备名、设备Ip地址、设备类型、用户名和密码。我们将该任务添加到threads列表中
for i in range(len(ipList)):
t=threading.Thread(target=NetmikoConfig,args=(deviceName,ipList[i],deviceType,username,password))
threads.append(t)
这里我理解的是,现在在threads这个列表变量中,我们已经将任务添加进去,之后,开启该列表中的任务即可。
if __name__=='__main__':
for i in range(len(ipList)):
threads[i].start()
在这里,为了避免主线程结束,而子线程还没有跑完,需要加入阻塞机制,这里使用的是join
join的左右就是线程同步,可以简单理解为,将子线程也join到主线程中,主线程需要等待子线程跑完后,主线程才会继续向下运行。
所以,这里有多少个线程,就都需要加入到主线程进行阻塞
for i in range(len(ipList)):threads[i].join()
这样,当子线程全部运行完成后,主线程才会继续执行。
总结:
本篇文章仅总结了如何创建线程和初步的使用线程的方法,面对多线程的需求,还有很多值得我们仅一步研究的东西,如如何应对多线程同时对一个数据进行修改,如何使用线程锁等等。而本文提到的针对同时登陆设备,进行操作这样的场景,不需要考虑这些问题,所以也比较简单。
这篇关于《Python多线程的初步使用》—人生苦短,我用Python(七)的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!