如何在Python中使用threading模塊

這篇文章將為大家詳細講解有關如何在Python中使用threading模塊，文章內容質量較高，因此小編分享給大家做個參考，希望大家閱讀完這篇文章后對相關知識有一定的了解。

多線程 - threading

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

1. 使用threading模塊

單線程執行

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

運行結果：

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

多線程執行

#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()#啟動線程

運行結果：

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

說明

①. 通過運行可以明顯看出使用多線程并發操作，花費時間要短很多。
②. 創建好的線程，需要調用 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. 查看線程數量

#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('當前運行的線程數為:' , length , ctime())
    if length <= 1:
      break
  # sleep(5)# 屏蔽此行代碼，試試看，程序是否會立即結束？
  print('------stop------' + ctime())

運行結果：

由于數量龐大，在此不展示。。。。。。

4.線程執行代碼的封裝 - 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 = 'ｉ am '+self.name+'@'+str(i) #name屬性中保存的是當前線程的名字
      print(msg)
if __name__ == "__main__":
  t = MyThread()
  t.start()

運行結果：

ｉ am Thread-1@0
ｉ am Thread-1@1
ｉ am Thread-1@2

說明：

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

5.線程的執行順序

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

運行結果：

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

說明：

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

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

run函數中每次循環的執行順序都不能確定。

總結

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

多線程-共享全局變量

#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中使用threading模塊就分享到這里了，希望以上內容可以對大家有一定的幫助，可以學到更多知識。如果覺得文章不錯，可以把它分享出去讓更多的人看到。