Python中的并发编程：锁、条件语句等问题实例

原创一时失言乱红尘 2024-12-28 09:48 46阅读 0赞

在Python中，我们可以使用多种机制来实现并发编程。以下是一些核心概念和问题实例：

1. **锁（Lock）**：
   - `threading.Lock()` 创建一个锁对象。
   - 示例：保护数据的共享读写。
   ```python
   lock = threading.Lock()

def read_data():
       with lock:
           return data  # 假设data是一个共享资源

def write_data(new_data):
       with lock:
           global data  # 修改全局变量
           data = new_data
   ```

2. **条件语句（Conditional Statements）**：
   - `if`, `elif`, `else`：基于某种条件执行代码。
   - 示例：多路分支选择，如等待某个任务完成再进行操作。
   ```python
   import threading

def task_to_complete():
       print("Task in progress...")
       time.sleep(5)  # 假设这是一个需要时间的任务
       print("Task completed.")

def main():
       task_thread = threading.Thread(target=task_to_complete)
       task_thread.start()  # 开始执行任务

if task_thread.is_alive():  # 检查任务是否还在运行
           print("Waiting for task to complete...")
           time.sleep(2)  # 等待一段时间
           print("Resuming tasks.")
       else:
           print("Task completed, resuming main loop.")

if __name__ == "__main__":
       main()
   ```

3. **线程池（Thread Pool）**：
   - `threading.Pool()` 创建一个线程池。
   - 示例：异步处理大量任务，提高效率。
   ```python
   from concurrent.futures import ThreadPoolExecutor

def worker(i):
       print(f"Processing task {i+1}}")

def main():
       with ThreadPoolExecutor(max_workers=5) as executor:
           tasks = [executor.submit(worker, i)) for i in range(10)]  # 分发10个任务

for future in tasks:  # 等待所有任务完成
           future.result()

print("All tasks completed.")

if __name__ == "__main__":
       main()
   ```

通过以上实例，你可以看到在Python中实现并发编程的各种方式。