繼承threading.Thread，并重寫run方法實現多線程，這里用到logging日志模塊是為了輸出好看一些，直接print的話會幾行疊在一起，不好看:

1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31

#!/usr/bin/python #coding:utf-8 import?threading import?datetime import?logging import?time logging.basicConfig(level?=?logging.DEBUG,format='(%(threadName)-10s) %(message)s',) list?=?['192.168.1.1','192.168.1.2'] class?Test(threading.Thread): ????def?__init__(self,ip): ????????threading.Thread.__init__(self) ????????self.ip?=?ip ?????????????????????????????????????????????????????????????????????????????? ????def?run(self): ????????logging.debug("%s start!"?%?self.ip) ????????time.sleep(5) ????????logging.debug('%s Done!'?%?self.ip) ?????????????????????????????????????????????????????????????????????????????????? ?????????????????????????????????????????????????????????????????????????????? if?__name__?==?"__main__":? ????#啟動線程 ????for?ip?in?list: ????????t?=?Test(ip) ????????t.start() ????#等待所有線程結束 ????for?t?in?threading.enumerate(): ????????if?t?is?threading.currentThread(): ????????????continue ????????t.join() ?????????????????????????????????????????????????????????????????????????????? ????logging.debug('Done!')

運行結果：

接著用Semaphore去控制線程數：

1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36

#!/usr/bin/python #coding:utf-8 import?threading import?datetime import?logging import?time logging.basicConfig(level?=?logging.DEBUG,format='(%(threadName)-10s) %(message)s',) list?=?['192.168.1.1','192.168.1.2'] class?Test(threading.Thread): ????def?__init__(self,threadingSum, ip): ????????threading.Thread.__init__(self) ????????self.ip?=?ip ????????self.threadingSum?=?threadingSum ????????????????????????????????????????????????????????????? ????def?run(self): ????????with?self.threadingSum: ????????????logging.debug("%s start!"?%?self.ip) ????????????time.sleep(5) ????????????logging.debug('%s Done!'?%?self.ip) ????????????????????????????????????????????????????????????????? ????????????????????????????????????????????????????????????? if?__name__?==?"__main__": ????#設置線程數 ????threadingSum?=?threading.Semaphore(1) ????????????????????????????????????????????????????????? ????#啟動線程 ????for?ip?in?list: ????????t?=?Test(threadingSum,ip) ????????t.start() ????#等待所有線程結束 ????for?t?in?threading.enumerate(): ????????if?t?is?threading.currentThread(): ????????????continue ????????t.join() ????????????????????????????????????????????????????????????? ????logging.debug('Done!')

運行結果：

接下來就根據需要來擴展run方法，滿足日常工作。

本文轉自運維筆記博客51CTO博客，原文鏈接http://blog.51cto.com/lihuipeng/1322247如需轉載請自行聯系原作者

lihuipeng

總結

以上是生活随笔為你收集整理的Python继承类的方式实现多线程及控制线程数的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。