如何在python線程中使用threading.Thread()函數

本文章向大家介紹如何在python線程中使用threading.Thread()函數的基本知識點總結和需要注意事項，具有一定的參考價值，需要的朋友可以參考一下。

python可以做什么

Python是一種編程語言，內置了許多有效的工具，Python幾乎無所不能，該語言通俗易懂、容易入門、功能強大，在許多領域中都有廣泛的應用，例如最熱門的大數據分析，人工智能，Web開發等。

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, args=(10, ), 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)

以上就是小編為大家帶來的如何在python線程中使用threading.Thread()函數的全部內容了，希望大家多多支持億速云！