Python線程之多線程展示詳解

什麼多線程?

多線程,就是多個獨立的運行單位,同時執行同樣的事情。

想想一下,文章發佈後同時被很多讀者閱讀,這些讀者在做的事情‘閱讀’就是一個一個的線程。
多線程就是多個讀者同時閱讀這篇文章。重點是:同時有多個讀者在做閱讀這件事情。

如果是多個讀者,分時間閱讀,最後任意時刻隻有一個讀者在閱讀,雖然是多個讀者,但還是單線程。

我們再拿前面分享的代碼:關註和點贊。

def dianzan_guanzhu():
    now = datetime.datetime.now()
    name = "python萌新"
    print("%s name:%s" % (now, name))
    time.sleep(1)
    result = "好棒!" + name + " 關註雷學委,學會瞭開發知識!"
    print("%s result:%s" % (now, result))
    return result

我們看看下面的代碼:

#!/usr/bin/env python
# -*- coding: utf-8 -*-
# @Time : 2021/11/21 12:02 上午
# @Author : LeiXueWei
# @CSDN/Juejin/Wechat: 雷學委
# @XueWeiTag: CodingDemo
# @File : __init__.py.py
# @Project : hello
import threading
import datetime
import time
def dianzan_guanzhu():
    now = datetime.datetime.now()
    name = "python萌新"
    print("%s name:%s" % (now, name))
    time.sleep(1)
    result = "好棒!" + name + " 關註雷學委,學會瞭開發知識!"
    print("%s result:%s" % (now, result))
    return result
for i in range(3):
    mythread = threading.Thread(name="t-" + str(i), target=dianzan_guanzhu)
    print("mythread:", mythread)
    print("is_alive:", mythread.is_alive())
    mythread.start()
    print("is_alive:", mythread.is_alive())

Thread類可以傳入name指定線程名字。

直接復制運行,這裡我們創建瞭3個線程。

它們依次調用瞭dianzan_guanzhu函數

下面是運行結果:

這3個線程不同時間打印完成瞭,但是內容打印亂序瞭,甚至還串行瞭。

讀者同學可以多運行幾次。

獲取活躍線程相關數據

  • threading.active_count函數: 可以獲取活躍線程數。
  • threading.current_thread函數:可以獲取活躍線程對象,這樣我們可以獲取這樣獲取線程名稱:threading.current_thread().getName()。

前文說過瞭,加上主線程,一共是4個線程。

運行下面代碼看看:

#!/usr/bin/env python
# -*- coding: utf-8 -*-
# @Time : 2021/11/21 12:02 上午
# @Author : LeiXueWei
# @CSDN/Juejin/Wechat: 雷學委
# @XueWeiTag: CodingDemo
# @File : __init__.py.py
# @Project : hello
import random
import threading
import datetime
import time
def dianzan_guanzhu():
    thread_name = threading.current_thread().getName()
    now = datetime.datetime.now()
    print("線程啟動瞭:", thread_name)
    name = "python萌新"+thread_name
    print("%s - %s name:%s" % (thread_name, now, name))
    time.sleep(1)
    result = "好棒!" + name + " 關註雷學委,學會瞭開發知識!"
    print("%s - %s result:%s" % (thread_name, now, result))
    return result
for i in range(3):
    mythread = threading.Thread(name="t-" + str(i), target=dianzan_guanzhu)
    print("mythread:", mythread)
    print("is_alive:", mythread.is_alive())
    mythread.start()
    ac = threading.active_count()
    print("active_count:", ac)

如果我們把活躍線程數打印,那麼等3個線程都start調用瞭。

加上主線程,最多是4個活躍線程。

今天先展示一下多個線程執行同個任務的代碼實現。

總結

本篇文章就到這裡瞭,希望能夠給你帶來幫助,也希望您能夠多多關註WalkonNet的更多內容!

推薦閱讀: