本文主要是介绍Python开启线程,函数中开线程,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!
Python开启线程,函数中开线程
逻辑处理上分成了多个模块,为了提高效率,前一个模块处理完调用后一个模块操作时使用多线程
我这里遇到的情形是前面取数据后面存到mysql,发现单线程效率很低,改为取数据后开线程存到mysql
开启线程之后性能提升一倍,同时用信号量做线程同步,控制数据库同时连接数
这里只是简单的一个demo,主要是开线程的处理方式,在自己类里面的函数中开启线程,并用自己类的成员函数做线程运行函数。
#coding=utf-8
import threadingclass Test:__init = 1def __init__(self):self.__sem = threading.Semaphore(value=5)#初始化信号量,最大并发数returndef handle(self, data):#开启线程,传入参数_thread = threading.Thread(target=self.__run, args=(data,))_thread.setDaemon(True)_thread.start()#启动线程returndef __run(self, data):self.__sem.acquire()#信号量减1self.__init +=dataprint(self.__init)self.__sem.release()#信号量加1returnif __name__=="__main__":test = Test()test.handle(1)print("end")
这篇关于Python开启线程,函数中开线程的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!