Python并发编程：多线程与进程案例分析

原创亦凉 2024-12-20 19:51 109阅读 0赞

在Python中，我们可以使用多种方式来进行并发编程，主要包括多线程和进程。下面我将通过具体的案例来分析这两种并发方式。

### 1. 多线程

**案例一：** 使用threading模块创建多线程。

```python
import threading

# 定义一个要线程化的函数
def worker(num):
    """线程中的工作"""
    print(f'Thread {num} is running...')

# 创建多个线程并启动它们
threads = []
for i in range(3):  # 创建3个线程
    thread = threading.Thread(target=worker, args=(i,)))
    threads.append(thread)  # 将线程添加到列表中
    thread.start()  # 启动线程

# 等待所有线程完成
for thread in threads:
    thread.join()
```

**案例二：** 使用asyncio模块实现异步多线程。

```python
import asyncio

# 定义一个需要异步执行的函数
async def worker(num):
    """异步线程中的工作"""
    await asyncio.sleep(1)  # 模拟耗时操作
    print(f'Thread {num} is running...')

# 创建多个异步线程并启动它们
coroutines = []
for i in range(3):  # 创建3个线程
    coroutine = asyncio.ensure_future(worker(i)))
    coroutines.append(coroutine)  # 将线程添加到列表中

asyncio.run(asyncio.gather(*coroutines))))

# 等待所有异步线程完成
for coroutine in coroutines:
    coroutine.result()
```

### 2. 进程

**案例三：** 使用multiprocessing模块创建进程。

```python
import multiprocessing

def worker(num):
    """进程中的工作"""
    print(f'Process {num} is running...')

# 创建多个进程并启动它们
if __name__ == '__main__':
    processes = []
    for i in range(3):  # 创建3个进程
        process = multiprocessing.Process(target=worker, args=(i,)))
        processes.append(process)  # 将线程添加到列表中

for process in processes:
        process.start()

# 等待所有进程完成
    for process in processes:
        process.join()
```

以上就是Python并发编程中多线程和进程的案例分析。在实际开发中，会根据项目需求、任务性质等因素选择合适的并发方式。