### 阻塞与非阻塞、同步与异步的概念及示例 在Python中，阻塞与非阻塞、同步与异步是两个不同的概念，分别描述了进程或线程的行为以及任务的调用方式。以下将详细解释这些概念，并通过代码示例进行说明。 #### 1. 阻塞与非阻塞 阻塞和非阻塞主要描述的是进程或线程在等待某个事件（如I/O操作完成）时的行为。 - **阻塞模式**：当一个线程或进程发起一个请求（如读取文件或网络数据），如果该请求不能立即完成，则线程或进程会被挂起，直到请求完成为止[^3]。 - **非阻塞模式**：当一个线程或进程发起一个请求，无论请求是否能立即完成，都不会被挂起，而是会立即返回一个结果（如表示未完成的状态）。这需要程序不断轮询以检查请求是否完成。 ##### 示例代码：阻塞与非阻塞的Socket通信 ```python import socket # 阻塞模式 sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM) sock.connect(('example.com', 80)) # 连接服务器，此过程会阻塞 sock.sendall(b"GET / HTTP/1.1\r\nHost: example.com\r\n\r\n") # 发送请求 data = sock.recv(1024) # 接收数据，此过程会阻塞 print(data.decode()) # 非阻塞模式 sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM) sock.setblocking(False) # 设置为非阻塞模式 try: sock.connect(('example.com', 80)) # 尝试连接，不会阻塞 except BlockingIOError: pass # 如果连接尚未完成，抛出异常 ready = select.select([], [sock], [], 5) # 使用select检查连接是否完成 if ready[1]: # 检查写就绪状态 sock.sendall(b"GET / HTTP/1.1\r\nHost: example.com\r\n\r\n") data = sock.recv(1024) # 接收数据，可能需要多次尝试 print(data.decode()) ``` #### 2. 同步与异步 同步和异步主要描述的是任务的调用方式。 - **同步调用**：当一个进程发起一个任务调用时，会一直等待该任务完成，然后继续执行后续代码[^3]。 - **异步调用**：当一个进程发起一个任务调用时，不会等待任务完成，而是继续执行后续代码。任务完成后，通常通过回调函数、事件或其他机制通知调用方[^3]。 ##### 示例代码：同步与异步的任务执行 ```python import time # 同步示例 def task(): print("Task started") time.sleep(2) # 模拟耗时操作 print("Task completed") task() # 调用任务，会阻塞主线程 print("Main thread continues...") # 只有当task完成后才会执行 # 异步示例 (使用asyncio) import asyncio async def async_task(): print("Async task started") await asyncio.sleep(2) # 模拟异步耗时操作 print("Async task completed") async def main(): task = asyncio.create_task(async_task()) # 创建异步任务 print("Main thread continues...") await task # 等待任务完成 asyncio.run(main()) ``` #### 3. 结合阻塞与非阻塞、同步与异步 在实际应用中，阻塞与非阻塞、同步与异步可以结合使用。例如，在异步编程中，可以通过非阻塞的方式处理多个并发任务。 ##### 示例代码：异步非阻塞的Socket通信 ```python import asyncio async def fetch_data(reader, writer): writer.write(b"GET / HTTP/1.1\r\nHost: example.com\r\n\r\n") await writer.drain() # 确保数据发送完成 data = await reader.read(1024) # 非阻塞地读取数据 print(data.decode()) async def main(): reader, writer = await asyncio.open_connection('example.com', 80) await fetch_data(reader, writer) asyncio.run(main()) ``` #### 4. 总结 - 阻塞与非阻塞描述的是线程或进程在等待事件时的行为。 - 同步与异步描述的是任务的调用方式。 - 在现代编程中，异步非阻塞的方式常用于提高程序的并发性能，尤其是在I/O密集型场景下[^4]。 --- ###