最后活跃于 10 months ago

這段 Python 程式碼 使用 多執行緒 (Threading) 與工作佇列 (Queue) 來 處理 30 個工作項目,確保所有工作都執行完畢後,才會顯示 "All work completed" 訊息。

修订 d282580899cb6df7aeba8865a21fdd4b41293dde

work_thread_example.py 原始文件
1"""
2這段程式碼是建立一個執行緒來處理工作項目,並將 30 個工作項目放入工作佇列中。然後會等待所有工作都完成後才會印出 "All work completed" 的訊息。
3"""
4
5import threading
6import queue
7
8
9# 定義一個函式來處理工作項目
10def process_work_item(work_queue):
11 # 在這裡添加你的工作處理代碼
12 while not work_queue.empty():
13 # 從工作佇列中取出一個工作項目
14 work_item = work_queue.get()
15
16 # 在這裡添加你的工作處理代碼
17 pass
18 print(work_item)
19
20 # 通知工作佇列,已經處理完一個工作項目
21 work_queue.task_done()
22
23
24
25# 建立工作佇列
26work_queue = queue.Queue()
27
28# 將 30 個工作項目放入工作佇列中
29for i in range(30):
30 work_queue.put(i)
31
32# 建立執行緒
33worker = threading.Thread(target=process_work_item, args=(work_queue,))
34
35# 啟動執行緒
36worker.start()
37
38# 等待執行緒結束
39worker.join()
40
41# 印出完成訊息
42print("All work completed")
43
44