日韩久久久精品,亚洲精品久久久久久久久久久,亚洲欧美一区二区三区国产精品 ,一区二区福利

Python多線程threading模塊用法實例分析

系統(tǒng) 1693 0

本文實例講述了Python多線程threading模塊用法。分享給大家供大家參考,具體如下:

多線程 - threading

python的thread模塊是比較底層的模塊,python的threading模塊對thread做了一些包裝,可以更加方便的被使用。

1. 使用threading模塊

單線程執(zhí)行

            
#coding=utf-8
import time
def saySorry():
  print('跑一圈')
  time.sleep(1)
if __name__ == "__main__":
  for i in range(5):
    saySorry()


          

運行結果:

跑一圈
跑一圈
跑一圈
跑一圈
跑一圈

多線程執(zhí)行

            
#coding=utf-8
import threading
import time
def saySorry():
  print('跑一圈')
  time.sleep(1)
if __name__ == "__main__":
  for i in range(5):
    t = threading.Thread(target=saySorry)
    t.start()#啟動線程


          

運行結果:

跑一圈
跑一圈
跑一圈
跑一圈
跑一圈

說明

①. 通過運行可以明顯看出使用多線程并發(fā)操作,花費時間要短很多。
②. 創(chuàng)建好的線程,需要調用 start() 方法來啟動

2. 主線程會等待所有的子線程結束后才結束

            
#coding=utf-8
import threading
from time import sleep,ctime,time
def run():
  for i in range(3):
    print('在跑步...%d'%i)
    sleep(1)
def sing():
  for i in range(3):
    print('在唱歌...%d'%i)
    sleep(1)
if __name__ == "__main__":
  print('------start------' + ctime())
  t1 = threading.Thread(target=run)
  t2 = threading.Thread(target=sing)
  t1.start()#啟動線程
  t2.start()
  # sleep(5)# 屏蔽此行代碼,試試看,程序是否會立即結束?
  print('------stop------' + ctime())


          

運行結果:

------start------Thu Aug 24 13:38:28 2017
在跑步...0
------stop------Thu Aug 24 13:38:28 2017
在唱歌...0
在跑步...1
在唱歌...1
在跑步...2
在唱歌...2

3. 查看線程數(shù)量

            
#coding=utf-8
import threading
from time import sleep,ctime,time
def run():
  for i in range(3):
    print('在跑步...%d'%i)
    sleep(1)
def sing():
  for i in range(3):
    print('在唱歌...%d'%i)
    sleep(1)
if __name__ == "__main__":
  print('------start------' + ctime())
  t1 = threading.Thread(target=run)
  t2 = threading.Thread(target=sing)
  t1.start()#啟動線程
  t2.start()
  while True:
    length = len(threading.enumerate())
    print('當前運行的線程數(shù)為:' , length , ctime())
    if length <= 1:
      break
  # sleep(5)# 屏蔽此行代碼,試試看,程序是否會立即結束?
  print('------stop------' + ctime())


          

運行結果:

由于數(shù)量龐大,在此不展示。。。。。。

4.線程執(zhí)行代碼的封裝 - threading.Thread子類

            
#coding=utf-8
import threading
import time
class MyThread(threading.Thread):
  def run(self):
    for i in range(3):
      time.sleep(1)
      msg = 'i am '+self.name+'@'+str(i) #name屬性中保存的是當前線程的名字
      print(msg)
if __name__ == "__main__":
  t = MyThread()
  t.start()


          

運行結果:

i am Thread-1@0
i am Thread-1@1
i am Thread-1@2

說明:

python的 threading.Thread 類有一個run方法,用于定義線程的功能函數(shù),可以在自己的線程類中覆蓋該方法。在創(chuàng)建自己的線程實例后,通過Thread類的 start() 方法,可以啟動該線程,交給python虛擬機進行調度,當該線程獲得執(zhí)行的機會時,就會調用run方法執(zhí)行線程。

5.線程的執(zhí)行順序

            
#coding=utf-8
import threading
import time
class MyThread(threading.Thread):
  def run(self):
    for i in range(3):
      time.sleep(1)
      msg = 'i am '+self.name+'@'+str(i) #name屬性中保存的是當前線程的名字
      print(msg)
def test():
  for i in range(5):
    t = MyThread()
    t.start()
if __name__ == "__main__":
  test()


          

運行結果:

i am Thread-1@0
i am Thread-2@0
i am Thread-3@0
i am Thread-4@0
i am Thread-5@0
i am Thread-1@1
i am Thread-2@1
i am Thread-3@1
i am Thread-4@1
i am Thread-5@1
i am Thread-1@2
i am Thread-2@2
i am Thread-3@2
i am Thread-4@2
i am Thread-5@2

說明:

(運行的結果可能不一樣,但是大體是一致的)

從代碼的執(zhí)行結果我們可以看出,多線程程序的執(zhí)行順序是不確定的。當執(zhí)行到sleep語句時,線程將被阻塞(Blocked),到sleep結束后,線程進入就緒(Runnable)狀態(tài),等待調度。而線程調度將自行選擇一個線程執(zhí)行。上面的代碼中只能保證每個線程都運行完整個run函數(shù),但是線程的啟動順序、

run函數(shù)中每次循環(huán)的執(zhí)行順序都不能確定。

總結

1. 每個線程一定會有一個名字,盡管上面的例子中沒有指定線程對象的name,但是python會自動為線程指定一個名字。
2. 當線程的run()方法結束時該線程完成。
3. 無法控制線程調度程序,但可以通過別的方式來影響線程調度的方式。
4. 線程的幾種狀態(tài)

Python多線程threading模塊用法實例分析_第1張圖片

多線程-共享全局變量

            
#coding=utf-8
import threading
import time
g_num = 100
def work1():
  global g_num
  for i in range(3):
    g_num+=1
  print('work1 --- num = %d'%g_num)
def work2():
  global g_num
  print('work2 --- num = %d'%g_num)
if __name__ == "__main__":
  print('---start------g_num = %d'%g_num)
  t1 = threading.Thread(target=work1)
  t1.start()
  # 延時一會,保證t1線程中的事情做完
  time.sleep(1)
  t2 = threading.Thread(target=work2)
  t2.start()


          

運行結果:

---start------g_num = 100
work1 --- num = 103
work2 --- num = 103

更多關于Python相關內容感興趣的讀者可查看本站專題:《Python進程與線程操作技巧總結》、《Python數(shù)據(jù)結構與算法教程》、《Python函數(shù)使用技巧總結》、《Python字符串操作技巧匯總》、《Python入門與進階經(jīng)典教程》、《Python+MySQL數(shù)據(jù)庫程序設計入門教程》及《Python常見數(shù)據(jù)庫操作技巧匯總》

希望本文所述對大家Python程序設計有所幫助。


更多文章、技術交流、商務合作、聯(lián)系博主

微信掃碼或搜索:z360901061

微信掃一掃加我為好友

QQ號聯(lián)系: 360901061

您的支持是博主寫作最大的動力,如果您喜歡我的文章,感覺我的文章對您有幫助,請用微信掃描下面二維碼支持博主2元、5元、10元、20元等您想捐的金額吧,狠狠點擊下面給點支持吧,站長非常感激您!手機微信長按不能支付解決辦法:請將微信支付二維碼保存到相冊,切換到微信,然后點擊微信右上角掃一掃功能,選擇支付二維碼完成支付。

【本文對您有幫助就好】

您的支持是博主寫作最大的動力,如果您喜歡我的文章,感覺我的文章對您有幫助,請用微信掃描上面二維碼支持博主2元、5元、10元、自定義金額等您想捐的金額吧,站長會非常 感謝您的哦!!!

發(fā)表我的評論
最新評論 總共0條評論
主站蜘蛛池模板: 墨竹工卡县| 伊宁市| 扶风县| 陵川县| 榆林市| 延津县| 张家界市| 南溪县| 汶川县| 长沙县| 庆安县| 包头市| 富源县| 嘉黎县| 庆云县| 宽城| 施秉县| 姜堰市| 沙湾县| 巍山| 胶州市| 唐山市| 南安市| 荔波县| 唐海县| 平泉县| 惠东县| 耿马| 新源县| 夹江县| 晴隆县| 康马县| 三亚市| 西畴县| 广安市| 锡林浩特市| 甘谷县| 新津县| 津市市| 南陵县| 通道|