編程學習網 > 編程語言 > Python > python 線程教程(Python多線程方法詳解)
2023
07-01

python 線程教程(Python多線程方法詳解)

本文介python多線程,關于多線程概念本文不過多介紹,主要介紹多線程的使用。

Python3 線程中常用的兩個模塊為:
_thread
threading (推薦使用)
thread 模塊已被廢棄。用戶可以使用 threading 模塊代替。所以,在 Python3 中不能再使用thread 模塊。為了兼容性,Python3 將 thread 重命名為 _thread。

1 _thread模塊使用
_thread 模塊通過函數start_new_thread來開啟新線程, 其使用方式如下:

_thread.start_new_thread(function, args[, kwargs] )
各個參數含義如下:

function: 線程函數,用于新線程起始執行。
args: 線程函數的參數,必須是個元組(tuple)類型。
kwargs: 可選參數。
以具體示例學習:

import _thread
import time

# 線程啟動函數
def worker( threadName, delay):
   while True:
        now = time.localtime() 
        print(threadName, time.strftime("%Y-%m-%d %H:%M:%S", now))
        time.sleep(delay)

# 開啟兩個線程
#線程1每秒打印一次
_thread.start_new_thread(worker, ("線程1", 1))
#線程2每4秒打印一次
_thread.start_new_thread(worker, ("線程2", 4))
 
# 通過循環,讓主線程不要退出
while 1:
   time.sleep(1000)
輸出結果如下:

線程1 2022-01-08 12:12:24
線程2 2022-01-08 12:12:24
線程1 2022-01-08 12:12:25
線程1 2022-01-08 12:12:26
線程1 2022-01-08 12:12:27
線程1 2022-01-08 12:12:28
線程2 2022-01-08 12:12:28
2 threading模塊使用
threading包含的方法
threading模塊包含_thread模塊中的所有方法,并且還包含如下方法:

threading.currentThread(): 返回當前的線程變量。
threading.enumerate(): 返回一個包含正在運行的線程的列表。正在運行指線程啟動后、結束前,不包括啟動前和終止后的線程。
threading.activeCount(): 返回正在運行的線程數量,與len(threading.enumerate())有相同的結果。
注意,在threading中沒有start_new_thread函數,而是更改為_start_new_thread函數

threading的Thread類
除了使用方法外,線程模塊同樣提供了Thread類來處理線程,Thread類提供了以下方法:

run(): 用以表示線程活動的方法。
start():啟動線程活動。
join([time]): 等待至線程中止。這阻塞調用線程直至線程的join()方法被調用中止、正常退出、拋出未處理的異常、超時發生等。
isAlive(): 返回線程是否活動的。
getName(): 返回線程名。
setName(): 設置線程名。
接下來我們介紹Thread類的方式開啟線程。

import threading
from threading import Thread
import time

class MyThread(Thread):
    def __init__(self, name, delay):
        threading.Thread.__init__(self)
        self.name = name
        self.delay = delay
        self.count = 0

    def run(self):
        print("進入線程", self.name)
        while self.count < 3:
            now = time.localtime() 
            print(self.name, time.strftime("%Y-%m-%d %H:%M:%S", now))
            time.sleep(self.delay)
            self.count += 1
        print("退出線程", self.name)

# 創建新線程
thread1 = MyThread("線程1", 1)
thread2 = MyThread("線程2", 4)

# 開啟新線程
thread1.start()
thread2.start()
thread1.join()
thread2.join()
print ("退出主線程")
輸出結果如下:

進入線程 線程1
線程1 2022-01-08 12:25:45
進入線程 線程2
線程2 2022-01-08 12:25:45
線程1 2022-01-08 12:25:46
線程1 2022-01-08 12:25:47
退出線程 線程1
線程2 2022-01-08 12:25:49
線程2 2022-01-08 12:25:53
退出線程 線程2
退出主線程

可以看到,線程2每次睡眠4秒,所以線程1運行結束后,線程2還在持續跑。等到所有線程結束,即thread1.join()和thread2.join()執行完成后,主線程才推出。

以上就是python 線程教程(Python多線程方法詳解)的詳細內容,想要了解更多Python教程歡迎持續關注編程學習網。

掃碼二維碼 獲取免費視頻學習資料

Python編程學習

查 看2022高級編程視頻教程免費獲取