逻辑处理上分成了多个模块,为了提高效率,前一个模块处理完调用后一个模块操作时使用多线程
我这里遇到的情形是前面取数据后面存到mysql,发现单线程效率很低,改为取数据后开线程存到mysql
开启线程之后性能提升一倍,同时用信号量做线程同步,控制数据库同时连接数
这里只是简单的一个演示,主要是开线程的处理方式,在自己类里面的函数中开启线程,并用自己类的成员函数做线程运行函数。
#=utf - 8编码
进口线程
类测试:
__init=1
def __init__(自我):
自我。__sem=threading.Semaphore (value=https://www.yisu.com/zixun/5) #初始化信号量,最大并发数
返回
def处理(自我、数据):
#开启线程,传入参数
_thread=threading.Thread(目标=自我。属于,arg游戏=(数据))
_thread.setDaemon(真正的)
_thread.start() #启动线程
返回
def属于(自我、数据):
self.__sem.acquire() #信号量减1
自我。__init +=数据
打印(self.__init)
self.__sem.release() #信号量加1
返回
if __name__==癬_main__”:
测试=测试()
test.handle (1)
打印(“结束”)
之前
以上这篇Python开启线程,在函数中开线程的实例就是小编分享给大家的全部内容了,希望能给大家一个参考,也希望大家多多支持。
