Python并发编程：多线程、多进程及锁机制案例

原创ゝ一世哀愁。 2025-02-12 10:09 0阅读 0赞

Python的并发编程主要涉及到多线程、多进程和锁机制。

1. **多线程**：
   - 使用`threading`模块创建线程。
   - 示例代码：
     ```python
     import threading

def worker(num):
         print(f"Worker {num} started")

# 创建线程
     threads = []
     for i in range(5):  # 每个线程处理的任务数
         thread = threading.Thread(target=worker, args=(i,)))
         threads.append(thread)
         thread.start()  # 启动线程

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

print("All workers finished.")
     ```
2. **多进程**：
   - 使用`multiprocessing`模块创建进程。
   - 示例代码：
     ```python
     import multiprocessing

def worker(num):
         print(f"Worker {num} started")

# 创建进程池，指定最大进程数
     pool = multiprocessing.Pool(processes=5)

# 使用进程池提交任务
     for i in range(10):  # 每个进程处理的任务数
         pool.apply_async(worker, args=(i,)))

# 关闭进程池
     pool.close()
     pool.join()

print("All workers finished.")
     ```
3. **锁机制（Lock）**：
   - `threading.Lock()` 创建一个锁对象。
   - 示例代码，多线程互斥访问资源：
     ```python
     import threading

# 定义资源和锁对象
     resource = ["resource1", "resource2"]
     lock = threading.Lock()

def worker(index):
         with lock:
             # 确保在获取锁后不会被其他线程阻塞
                 print(f"Worker {index} acquired lock"))
                 
                 # 互斥访问资源
                 resource[index] = "modified_resource"
                 
                 # 释放锁，允许其他线程获取
                 print(f"Worker {index} released lock"))

threads = []
     for i in range(2):  # 每个线程处理的任务数
         thread = threading.Thread(target=worker, args=(i,)))
         threads.append(thread)
         thread.start()  # 启动线程

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

print("All workers finished.")
     ```

以上就是Python并发编程中多线程、多进程及锁机制的简单示例。