用线程池把上面单个客户端改成多个客户端

为了用线程池支持多个客户端并发请求，我们可以创建一个线程池来管理任务的提交和执行。这样可以避免单个客户端的瓶颈，提高整体效率。下面是一个简化示例：

首先，我们需要导入必要的库并设置线程池大小：

from concurrent.futures import ThreadPoolExecutor

# 创建线程池，可以根据实际需求调整线程数量
pool_size = 5
executor = ThreadPoolExecutor(pool_size)

然后，对于每个客户端的请求，我们可以在单独的线程中异步执行：

def handle_client_request(client_id):
    # 这里代表客户端的具体业务逻辑
    # ...
    
async def submit_and_execute(client_request):
    future = executor.submit(handle_client_request, client_id)
    try:
        result = await future.result(timeout=10)  # 设置超时时间防止阻塞
        return result
    except Exception as e:
        print(f"Client {client_id} request failed: {e}")

# 示例：客户端列表
clients = [1, 2, 3, 4, 5]

# 提交任务给线程池
for client in clients:
    execute_future = submit_and_execute(client)

# 等待所有任务完成（如果不想阻塞，可以用`as_completed()`替代）
futures = {future: client for future in execute_future}
for future in concurrent.futures.as_completed(futures):
    client_id = futures[future]
    try:
        result = future.result()
        print(f"Client {client_id} response: {result}")
    except Exception as exc:
        print(f"Exception raised by Client {client_id}: {exc}")

在这个示例中，每个客户端请求都被提交到线程池，它们在各自的线程中并行执行。通过`timeout`参数，我们可以限制每个任务的运行时间，防止长时间占用资源。