1. 程式人生 > 程式設計 >python中的執行緒threading.Thread()使用詳解

python中的執行緒threading.Thread()使用詳解

1. 執行緒的概念:

執行緒,有時被稱為輕量級程序(Lightweight Process,LWP),是程式執行流的最小單元。一個標準的執行緒由執行緒ID,當前指令指標(PC),暫存器集合和堆疊組成。另外,執行緒是程序中的一個實體,是被系統獨立排程和分派的基本單位,執行緒自己不擁有系統資源,只擁有一點兒在執行中必不可少的資源,但它可與同屬一個程序的其它執行緒共享程序所擁有的全部資源。

2. threading.thread()的簡單使用

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

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()時,才會真正的建立執行緒,並且開始執行
  • 每個執行緒都有一個唯一標示符,來區分執行緒中的主次關係
  • 主執行緒:mainThread,Main函式或者程式主入口,都可以稱為主執行緒
  • 子執行緒:Thread-x 使用 threading.Thread() 創建出來的都是子執行緒
  • 執行緒數量:主執行緒數 + 子執行緒數

2.2 主執行緒會等待所有的子執行緒結束後才結束

import threading
from time import sleep,ctime

def sing():
  for i in range(3):
    print("正在唱歌...%d"%i)
    sleep(1)

def dance():
  for i in range(3):
    print("正在跳舞...%d"%i)
    sleep(1)

if __name__ == '__main__':
  print('---開始---:%s'%ctime())

  t1 = threading.Thread(target=sing)
  t2 = threading.Thread(target=dance)

  t1.start()
  t2.start()

  #sleep(5) # 遮蔽此行程式碼,試試看,程式是否會立馬結束?
  print('---結束---:%s'%ctime())

在這裡插入圖片描述

3.檢視執行緒數量

import threading
from time import sleep,ctime

def sing():
  for i in range(3):
    print("正在唱歌...%d"%i)
    sleep(1)

def dance():
  for i in range(3):
    print("正在跳舞...%d"%i)
    sleep(1)

if __name__ == '__main__':
  print('---開始---:%s'%ctime())

  t1 = threading.Thread(target=sing)
  t2 = threading.Thread(target=dance)

  t1.start()
  t2.start()

  while True:
    length = len(threading.enumerate())
    print('當前執行的執行緒數為:%d'%length)
    if length<=1:
      break

    sleep(0.5)

在這裡插入圖片描述

4.執行緒引數及順序

4.1 傳遞引數的方法:

  • 使用args 傳遞引數 threading.Thread(target=sing,args=(10,100,100))
  • 使用kwargs傳遞引數 threading.Thread(target=sing,kwargs={“a”: 10,“b”:100,“c”: 100})
  • 同時使用 args 和 kwargs 傳遞引數 threading.Thread(target=sing,),kwargs={“b”: 100,“c”: 100})

4.2 執行緒的執行順序

import socket
import threading
import time

def sing():
  for i in range(10):
    print("------------------------------")
    time.sleep(0.5)
    
def dance():
  for i in range(10):
    print("-----")
    time.sleep(0.5)

if __name__ == '__main__':
  # 建立兩個子執行緒
  t1 = threading.Thread(target=sing)
  t2 = threading.Thread(target=dance)
  # 啟動子執行緒
  t1.start()
  t2.start()

說明:

從程式碼和執行結果我們可以看出,多執行緒程式的執行順序是不確定的。當執行到sleep語句時,執行緒將被阻塞(Blocked),到sleep結束後,執行緒進入就緒(Runnable)狀態,等待排程。而執行緒排程將自行選擇一個執行緒執行。上面的程式碼中只能保證每個執行緒都執行完整個run函式,但是執行緒的啟動順序、run函式中每次迴圈的執行順序都不能確定。

5. 守護執行緒

守護執行緒:如果在程式中將子執行緒設定為守護執行緒,則該子執行緒會在主執行緒結束時自動退出,設定方式為thread.setDaemon(True),要在thread.start()之前設定,預設是false的,也就是主執行緒結束時,子執行緒依然在執行。

5.1 如下程式碼,主執行緒已經exit() 【其實並沒有真正結束】,子執行緒還在繼續執行

import threading
import time

def test():
  for i in range(10):
    print("test is run:",i)
    time.sleep(1)

if __name__ == '__main__':
  # 建立子執行緒
  t1 = threading.Thread(target=test)
  # 啟動子執行緒
  t1.start()
  # 休眠2秒
  time.sleep(2)
  print("我 OVER 了")
  # 退出
  exit()

在這裡插入圖片描述

5.2 設定守護執行緒

設定為守護執行緒(如果主執行緒結束了,也隨之結束)
執行緒.setDaemon(True)

在這裡插入圖片描述

以上就是本文的全部內容,希望對大家的學習有所幫助,也希望大家多多支援我們。