加入收藏 | 设为首页 | 会员中心 | 我要投稿 湖南网 (https://www.hunanwang.cn/)- 科技、建站、经验、云计算、5G、大数据,站长网!
当前位置: 首页 > 建站 > 正文

一篇文章读懂 Python 多线程

发布时间:2019-09-25 01:31:04 所属栏目:建站 来源:编程派
导读:Threading模块从 Python 1.5.2 版开始呈现,用于加强底层的多线程模块thread。Threading 模块让操纵多线程变得更简朴,而且支持措施同时运行多个操纵。 留意,Python 中的多线程最好用于处理赏罚有关 I/O 的操纵,如从网上下载资源可能从当地读取文件可能目次

更新后的代码如下:

  1. import logging 
  2. import threading 
  3.  
  4. class MyThread(threading.Thread): 
  5. def __init__(self, number, logger): 
  6. threading.Thread.__init__(self) 
  7. self.number = number 
  8. self.logger = logger 
  9.  
  10. def run(self): 
  11. """ 
  12. 运行线程 
  13. """ 
  14. logger.debug('Calling doubler') 
  15. doubler(self.number, self.logger) 
  16.  
  17. def get_logger: 
  18. logger = logging.getLogger("threading_example") 
  19. logger.setLevel(logging.DEBUG) 
  20.  
  21. fh = logging.FileHandler("threading_class.log") 
  22. fmt = '%(asctime)s - %(threadName)s - %(levelname)s - %(message)s' 
  23. formatter = logging.Formatter(fmt) 
  24. fh.setFormatter(formatter) 
  25.  
  26. logger.addHandler(fh) 
  27. return logger 
  28.  
  29. def doubler(number, logger): 
  30. """ 
  31. 可以被线程行使的一个函数 
  32. """ 
  33. logger.debug('doubler function executing') 
  34. result = number * 2 
  35. logger.debug('doubler function ended with: {}'.format( 
  36. result)) 
  37.  
  38. if __name__ == '__main__': 
  39. logger = get_logger 
  40. thread_names = ['Mike', 'George', 'Wanda', 'Dingbat', 'Nina'] 
  41. for i in range(5): 
  42. thread = MyThread(i, logger) 
  43. thread.setName(thread_names[i]) 
  44. thread.start 

这个例子中,我们只是建设一个担任于 threading.Thread的子类。像之前一样,传入一个必要翻一番的数字,以及 logging 工具。可是这次,配置线程名称的方法有点不太一样,酿成了通过挪用 thread 工具的setName要领来配置。不外如故必要挪用start来启动线程,不外你也许留意到我们并不必要在子类中界说该要领。当挪用start时,它会通过挪用run要领来启动线程。在我们的类中,我们挪用 doubler 函数来做处理赏罚。输出功效中除了一些添加的特殊信息内容险些差不多。运行下这个剧本,看看你会获得什么。

线程锁与线程同步

当你有多个线程,就必要思量奈何停止线程斗嘴。我的意思是说,你也许碰着多个线程同时会见统一资源的环境。假如不思量这些题目而且拟定响应的办理方案,那么在开拓产物进程中,你总会在最糟糕的时辰碰着这些棘手的题目。

办理步伐就是行使线程锁。锁由 Python 的 threading 模块提供,而且它最多被一个线程所持有。当一个线程试图获取一个已经锁在资源上的锁时,该线程凡是会停息运行,直到这个锁被开释。来让我们看一个很是典范没有却应具备锁成果的例子:

  1. import threading 
  2.  
  3. total = 0 
  4.  
  5. def update_total(amount): 
  6. """ 
  7. Updates the total by the given amount 
  8. """ 
  9. global total 
  10. total += amount 
  11. print (total) 
  12. if __name__ == '__main__': 
  13. for i in range(10): 
  14. my_thread = threading.Thread( 
  15. target=update_total, args=(5,)) 
  16. my_thread.start 

(编辑:湖南网)

【声明】本站内容均来自网络,其相关言论仅代表作者个人观点,不代表本站立场。若无意侵犯到您的权利,请及时与联系站长删除相关内容!

热点阅读