python开启两个线程
Python开启线程,在函数中开线程的实例逻辑处理上分成了多个模块,为了提高效率,前一个模块处理完调用后一个模块操作时使用多线程
我这里遇到的情形是前面取数据后面存到mysql,发现单线程效率很低,改为取数据后开线程存到mysql
开启线程之后性能提升一倍,同时用信号量做线程同步,控制数据库同时连接数
这里只是简单的一个demo,主要是开线程的处理方式,在自己类里面的函数中开启线程,并用自己类的成员函数做线程运行函数。
|
#coding=utf-8 import threading class Test: __init = 1 def __init__( self ): self .__sem = threading.Semaphore(value = 5 ) #初始化信号量,最大并发数 return def handle( self , data): #开启线程,传入参数 _thread = threading.Thread(target = self .__run, args = (data,)) _thread.setDaemon( True ) _thread.start() #启动线程 return def __run( self , data): self .__sem.acquire() #信号量减1 self .__init + = data print ( self .__init) self .__sem.release() #信号量加1 return if __name__ = = "__main__" : test = Test() test.handle( 1 ) print ( "end" ) |
以上这篇Python开启线程,在函数中开线程的实例就是小编分享给大家的全部内容了,希望能给大家一个参考,也希望大家多多支持开心学习网。
原文链接:https://blog.csdn.net/u011261430/article/details/72958711