Python并发编程：任务调度、线程池及异步IO的实战案例

原创阳光穿透心脏的1/2处 2025-03-23 07:24 75阅读 0赞

在Python中，我们可以通过多种方式来实现并发编程。以下是几种主要的实现方式及其实战案例：

1. **使用多线程（Thread）**：
   - 简单示例：创建两个线程分别打印数字。
   ```python
   import threading

def print_numbers(n):
       for i in range(n):
           print(i)

# 创建并启动线程
   thread1 = threading.Thread(target=print_numbers, args=(5,)))
   thread2 = threading.Thread(target=print_numbers, args=(3,)))

thread1.start()
   thread2.start()

thread1.join()
   thread2.join()
   ```

2. **使用多进程（Process）**：
   - 简单示例：创建两个子进程分别计算斐波那契数列。
   ```python
   import multiprocessing

def fib(n):
       a, b = 0, 1
       for _ in range(n):
           a, b = b, a + b
       return a

# 创建并启动进程
   p1 = multiprocessing.Process(target=fib, args=(50,))))
   p2 = multiprocessing.Process(target=fib, args=(30,))))

p1.start()
   p2.start()

p1.join()
   p2.join()
   ```

3. **使用线程池（ThreadPoolExecutor）**：
   - 简单示例：创建一个线程池，执行n次斐波那契计算。
   ```python
   from concurrent.futures import ThreadPoolExecutor

def fib(n, thread_pool):
       with thread_pool:
           return fib(n-1, thread_pool) + fib(n-2, thread_pool))

n = 50
   pool_size = 5  # 线程池大小

with ThreadPoolExecutor(max_workers=pool_size) as executor:
       result = executor.submit(fib, n, executor))
       print(result.result())  # 输出最终斐波那契数列的结果
   ```

4. **使用异步IO（asyncio）**：
   - 简单示例：创建一个异步任务，计算斐波那契数列。
   ```python
   import asyncio

async def fib(n):
       a, b = 0, 1
       for _ in range(n):
           a, b = b, a + b
       return a

n = 50
   coro = fib(n)

loop = asyncio.get_event_loop()
   try:
       result = loop.run_until_complete(coro)
       print(result)  # 输出最终斐波那契数列的结果
   finally:
       loop.close()
   ```

以上是Python并发编程中任务调度、线程池和异步IO的基本实战案例。根据实际需求，可以灵活选择不同的并发模型来实现业务处理。