快捷導(dǎo)航

python中的線程threading.Thread()使用詳解

更新時間：2019年12月17日 14:24:51 作者：SpiderLiH

這篇文章主要介紹了python中的線程threading.Thread()使用詳解，文中通過示例代碼介紹的非常詳細(xì)，對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值，需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧

1. 線程的概念：

線程，有時被稱為輕量級進(jìn)程(Lightweight Process，LWP），是程序執(zhí)行流的最小單元。一個標(biāo)準(zhǔn)的線程由線程ID，當(dāng)前指令指針(PC），寄存器集合和堆棧組成。另外，線程是進(jìn)程中的一個實(shí)體，是被系統(tǒng)獨(dú)立調(diào)度和分派的基本單位，線程自己不擁有系統(tǒng)資源，只擁有一點(diǎn)兒在運(yùn)行中必不可少的資源，但它可與同屬一個進(jìn)程的其它線程共享進(jìn)程所擁有的全部資源。

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() #啟動線程，即讓線程開始執(zhí)行

運(yùn)行結(jié)果：

在這里插入圖片描述

使用說明：

可以明顯看出使用了多線程并發(fā)的操作，花費(fèi)時間要短很多
當(dāng)調(diào)用start()時，才會真正的創(chuàng)建線程，并且開始執(zhí)行
每個線程都有一個唯一標(biāo)示符，來區(qū)分線程中的主次關(guān)系
主線程:mainThread,Main函數(shù)或者程序主入口，都可以稱為主線程
子線程:Thread-x 使用 threading.Thread() 創(chuàng)建出來的都是子線程
線程數(shù)量：主線程數(shù) + 子線程數(shù)

2.2 主線程會等待所有的子線程結(jié)束后才結(jié)束

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) # 屏蔽此行代碼，試試看，程序是否會立馬結(jié)束？
  print('---結(jié)束---:%s'%ctime())

在這里插入圖片描述

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

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āng)前運(yùn)行的線程數(shù)為：%d'%length)
    if length<=1:
      break

    sleep(0.5)

在這里插入圖片描述

4.線程參數(shù)及順序

4.1 傳遞參數(shù)的方法：

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

4.2 線程的執(zhí)行順序

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__':
  # 創(chuàng)建兩個子線程
  t1 = threading.Thread(target=sing)
  t2 = threading.Thread(target=dance)
  # 啟動子線程
  t1.start()
  t2.start()

說明:

從代碼和執(zhí)行結(jié)果我們可以看出，多線程程序的執(zhí)行順序是不確定的。當(dāng)執(zhí)行到sleep語句時，線程將被阻塞（Blocked），到sleep結(jié)束后，線程進(jìn)入就緒（Runnable）狀態(tài)，等待調(diào)度。而線程調(diào)度將自行選擇一個線程執(zhí)行。上面的代碼中只能保證每個線程都運(yùn)行完整個run函數(shù)，但是線程的啟動順序、run函數(shù)中每次循環(huán)的執(zhí)行順序都不能確定。

5. 守護(hù)線程

守護(hù)線程：如果在程序中將子線程設(shè)置為守護(hù)線程，則該子線程會在主線程結(jié)束時自動退出，設(shè)置方式為thread.setDaemon(True)，要在thread.start()之前設(shè)置，默認(rèn)是false的，也就是主線程結(jié)束時，子線程依然在執(zhí)行。

5.1 如下代碼，主線程已經(jīng)exit() 【其實(shí)并沒有真正結(jié)束】，子線程還在繼續(xù)執(zhí)行

import threading
import time

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

if __name__ == '__main__':
  # 創(chuàng)建子線程
  t1 = threading.Thread(target=test)
  # 啟動子線程
  t1.start()
  # 休眠2秒
  time.sleep(2)
  print("我 OVER 了")
  # 退出
  exit()

在這里插入圖片描述