Python开启线程,在函数中开线程的实例_Python

Python开启线程,在函数中开线程的实例

2021-06-01 00:14仅仅学会简单 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")