1. 線程的概念：

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

2. threading.thread()的簡(jiǎn)單使用

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

import threading
import time

def saySorry():
  print("親愛的，我錯(cuò)了，我能吃飯了嗎？")
  time.sleep(1)

if __name__ == "__main__":
  for i in range(5):
    t = threading.Thread(target=saySorry)
    t.start() #啟動(dòng)線程，即讓線程開始執(zhí)行

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

使用說明：

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

2.2 主線程會(huì)等待所有的子線程結(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) # 屏蔽此行代碼，試試看，程序是否會(huì)立馬結(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})
• 同時(shí)使用 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)建兩個(gè)子線程
  t1 = threading.Thread(target=sing)
  t2 = threading.Thread(target=dance)
  # 啟動(dòng)子線程
  t1.start()
  t2.start()

說明:

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

5. 守護(hù)線程

守護(hù)線程：如果在程序中將子線程設(shè)置為守護(hù)線程，則該子線程會(huì)在主線程結(jié)束時(shí)自動(dòng)退出，設(shè)置方式為thread.setDaemon(True)，要在thread.start()之前設(shè)置，默認(rèn)是false的，也就是主線程結(jié)束時(shí)，子線程依然在執(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)
  # 啟動(dòng)子線程
  t1.start()
  # 休眠2秒
  time.sleep(2)
  print("我 OVER 了")
  # 退出
  exit()

5.2 設(shè)置守護(hù)線程

設(shè)置為守護(hù)線程（如果主線程結(jié)束了，也隨之結(jié)束）
線程.setDaemon(True)

以上就是本文的全部?jī)?nèi)容，希望對(duì)大家的學(xué)習(xí)有所幫助，也希望大家多多支持腳本之家。

最新評(píng)論