Python - 線程優先級

嗨，有抱負的程式設計師們！今天，我們將深入探討 Python 程式設計中的一個令人興奮的主題：線程優先級。作為您友善的鄰居電腦老師，我將引導您逐步走過這段旅程。如果您是程式設計的新手，也別擔心；我們將從基礎開始，逐步進階。所以，拿起您最喜歡的飲料，放鬆一下，讓我們一起踏上這段 Python 的冒險之旅！

Python - Thread Priority

了解線程與優先級

在我們深入探討線程優先級的細節之前，先花點時間了解線程是什麼。想像您在一個忙碌的廚房中，您是主廚。您有許多任務要完成：切菜、攪湯、烤蛋糕。而不是一次完成這些任務，您可以指派不同的廚師（線程）同時進行這些任務。這基本上就是線程在程式設計中所做的事——它們允許程式同時執行多個任務。

現在，線程優先級就像是指派這些任務的重要性。就像您可能會在甜點之前優先準備主菜一樣，您可以在 Python 程式中優先處理某些線程。

使用 Sleep() 設定線程優先級

在 Python 中影響線程優先級的一個簡單方法是使用 sleep() 函數。這種方法雖然不直接設定優先級，但可以幫助管理不同線程的執行時間。

讓我們看一個例子：

import threading
import time

def task(name, sleep_time):
print(f"Task {name} started")
time.sleep(sleep_time)
print(f"Task {name} completed")

# 創建線程
thread1 = threading.Thread(target=task, args=("A", 2))
thread2 = threading.Thread(target=task, args=("B", 1))

# 開始線程
thread1.start()
thread2.start()

# 等待線程完成
thread1.join()
thread2.join()

print("All tasks completed")

在這個例子中，我們創建了兩個執行 task 函數的線程。任務 A 休眠 2 秒，而任務 B 休眠 1 秒。即使我們首先開始任務 A，任務 B 將可能因為較短的休眠時間而先完成。

當您運行此代碼時，您將看到類似以下內容：

Task A started
Task B started
Task B completed
Task A completed
All tasks completed

這演示了如何使用 sleep() 影響線程的執行順序和持續時間。

在 Windows 上調整 Python 線程優先級

在 Windows 系統上，Python允許我們更直接地設定線程優先級。我們可以使用 pywin32 套件中的 win32process 模塊來調整線程優先級。

首先，您需要安裝 pywin32：

pip install pywin32

現在，讓我們看看一個例子：

import threading
import time
import win32api
import win32process
import win32con

def set_thread_priority(priority):
handle = win32api.GetCurrentThread()
win32process.SetThreadPriority(handle, priority)

def task(name, priority):
set_thread_priority(priority)
print(f"Task {name} started with priority {priority}")
time.sleep(2)
print(f"Task {name} completed")

# 創建線程
thread1 = threading.Thread(target=task, args=("A", win32process.THREAD_PRIORITY_BELOW_NORMAL))
thread2 = threading.Thread(target=task, args=("B", win32process.THREAD_PRIORITY_ABOVE_NORMAL))

# 開始線程
thread1.start()
thread2.start()

# 等待線程完成
thread1.join()
thread2.join()

print("All tasks completed")

在這個例子中，我們將任務 A 設定為低於正常優先級，將任務 B 設定為高於正常優先級。Windows 作業系統將嘗試為任務 B 分配更多的 CPU 時間，從而可能使其更快完成。

使用 Queue 模塊優先處理 Python 線程

管理線程優先級的另一種方法是使用 Python 的 Queue 模塊。雖然它不直接設定優先級，但它允許我們控制任務處理的順序。

以下是一個例子：

import threading
import queue
import time

def worker(q, name):
while True:
task = q.get()
if task is None:
break
print(f"Worker {name} processing task: {task}")
time.sleep(1)
q.task_done()

# 創建一個優先隊列
q = queue.PriorityQueue()

# 將任務添加到隊列（數字越小 = 優先級越高）
q.put((2, "Low priority task"))
q.put((1, "High priority task"))
q.put((3, "Lowest priority task"))

# 創建並啟動工作線程
threads = []
for i in range(2):
t = threading.Thread(target=worker, args=(q, i))
t.start()
threads.append(t)

# 等待所有任務完成
q.join()

# 停止工作線程
for i in range(2):
q.put(None)

for t in threads:
t.join()

print("All tasks completed")

在這個例子中，我們使用 PriorityQueue 來管理任務。優先級較低的任務（數字較小）將首先被處理。這允許我們優先處理某些任務。

結論

就是這樣，我親愛的學生們！我們已經探討了在 Python 中管理線程優先級的三種不同方法。請記住，就像一個精心指揮的廚房一樣，管理線程優先級可以幫助您的程式更有效地運行。

以下是我們涵蓋的方法的快速總結：

方法	優點	缺點
使用 sleep()	實現簡單	不直接設定優先級
Windows 特定優先級	直接控制線程優先級	只在 Windows 系統上工作
Queue 模塊	在所有系統上工作，允許細粒度控制	需要更複雜的實現

隨著您繼續 Python 的旅程，您將發現理解線程優先級對於優化您的程式非常有用。請持續練習，保持好奇心，並且不要害怕實驗。編程愉快！

Credits: Image by storyset