Python - 多线程

大家好，未来的Python巫师们！今天，我们将踏上一段令人兴奋的旅程，深入了解Python中的多线程。如果你是编程新手，也无需担心；我将作为你的友好向导，一步一步地探索这个主题。所以，拿起你的虚拟魔杖（键盘），让我们开始吧！

Python - Multithreading

什么是多线程？

在我们用Python线程施展魔法之前，先来了解一下多线程的奥秘。想象一下，你是一个忙碌厨房中的厨师。如果你一个人烹饪，一次只能做一项任务——切菜、然后烧水、然后煎肉。但是，如果你有多个手可以同时做不同的任务呢？这正是多线程为我们的程序所做的！

多线程允许程序在单个进程内并发执行多个任务。这就好比有多个厨师（线程）在同一个厨房（进程）中协同工作，以更快、更有效率的方式准备一顿美味的饭菜（程序输出）。

与进程的比较

现在，你可能会想，“但是老师，我也听说过进程。线程和进程有什么区别？”这是一个好问题！让我们来分析一下：

资源使用：线程就像共享一个房间（内存空间）的兄弟姐妹，而进程则像是拥有独立房子的邻居。线程更轻量级，并且共享资源，因此在某些任务上更有效率。
通信：线程可以通过共享变量轻松地“聊天”，但进程需要使用特殊的“电话”（进程间通信）来交谈。
开销：创建和管理线程通常比进程更快，需要的系统资源也更少。
复杂性：虽然线程可以使你的程序更快，但它们也引入了复杂性。这就像玩杂耍——如果你做得好，既有趣又高效，但如果你不小心，可能会把球掉地上！

Python中的线程处理模块

Python作为一个慷慨的语言，为我们提供了多个模块来处理线程。其中两个主要的模块是：

threading：这是处理线程的高级接口。它就像一个友好的巫师学徒，为你完成大部分重活。
_thread：这是低级接口。它就像一本古老的魔法书——功能强大，但需要更多的专业知识才能正确使用。

今天我们的魔法之旅将集中在threading模块上，因为它更适合初学者，并且被广泛使用。

启动新线程

好了，让我们施展第一个线程魔法！以下是创建和启动新线程的方法：

import threading
import time

def print_numbers():
for i in range(5):
time.sleep(1)
print(f"线程 1: {i}")

# 创建一个新线程
thread1 = threading.Thread(target=print_numbers)

# 启动线程
thread1.start()

# 主线程继续执行
for i in range(5):
time.sleep(1)
print(f"主线程: {i}")

# 等待thread1完成
thread1.join()

print("全部完成！")

让我们来解析一下这个魔法咒语：

我们导入了threading和time模块。
我们定义了一个函数print_numbers()，它将由我们的线程执行。
我们创建了一个新的线程对象，并指定了它应该运行的函数。
我们使用start()方法启动线程。
主线程继续执行它自己的循环。
我们使用join()等待线程完成，然后程序结束。

运行这个代码，你会看到来自两个线程的数字交错打印，展示了并发执行！

同步线程

现在，想象一下我们的厨师助手试图同时使用同一把刀——一片混乱，对吧？这就是线程同步的用武之地。我们使用锁来确保一次只有一个线程可以访问共享资源。

以下是一个例子：

import threading
import time

# 共享资源
counter = 0
lock = threading.Lock()

def increment_counter():
global counter
for _ in range(100000):
lock.acquire()
counter += 1
lock.release()

# 创建两个线程
thread1 = threading.Thread(target=increment_counter)
thread2 = threading.Thread(target=increment_counter)

# 启动线程
thread1.start()
thread2.start()

# 等待两个线程完成
thread1.join()
thread2.join()

print(f"计数器的最终值: {counter}")

在这个例子中，我们使用一个锁来确保一次只有一个线程可以增加计数器的值，防止竞争条件。

多线程优先队列

最后但同样重要的是，让我们来看一个多线程的实际应用——优先队列。想象一下医院的急诊室，患者是根据病情的严重程度而不是仅仅根据到达时间接受治疗的。

import threading
import queue
import time
import random

# 创建一个优先队列
task_queue = queue.PriorityQueue()

def worker():
while True:
priority, task = task_queue.get()
print(f"处理任务: {task} (优先级: {priority})")
time.sleep(random.uniform(0.1, 0.5))  # 模拟工作
task_queue.task_done()

# 创建并启动工作线程
for _ in range(3):
thread = threading.Thread(target=worker, daemon=True)
thread.start()

# 向队列添加任务
for i in range(10):
priority = random.randint(1, 5)
task = f"任务 {i}"
task_queue.put((priority, task))

# 等待所有任务完成
task_queue.join()
print("所有任务完成！")

这个例子展示了多个线程如何高效地协同处理优先队列中的任务。

结论

恭喜你，年轻的Pythonista们！你已经迈出了进入神奇的多线程领域的第一步。记住，力量越大，责任越大——明智地使用线程，它们将使你的程序更快、更高效。

以下是我们今天涵盖的主要线程方法的快速参考表：

方法	描述
`Thread(target=function)`	创建一个新线程来运行指定的函数
`start()`	开始线程的活动
`join()`	等待线程完成
`Lock()`	创建一个线程同步锁
`acquire()`	获取一个锁
`release()`	释放一个锁

继续练习，保持好奇，很快你就能像一个真正的Python大师一样指挥线程了！祝编程愉快！

Credits: Image by storyset