以上代码 在合适的地方帮我加上线程池

为了提高并发处理能力，我们可以在处理客户端请求的部分引入一个线程池。这里以C++标准库中的`std::thread_pool`为例，首先需要包含头文件`<execution>`。以下是在上述代码中加入线程池的部分示例：

#include <execution>
#include <thread_pool>

using namespace std::execution;

class ThreadPoolManager {
public:
    ThreadPoolManager(size_t pool_size) : pool(pool_size) {}

    void enqueue_task(std::function<void()> task) {
        pool.submit(task);
    }

private:
    thread_pool<> pool;
};

// 修改handle_client_connection函数，创建一个线程池管理器并异步处理任务
void handle_client_connection(int client_fd, const epoll_event& event, ThreadPoolManager& thread_pool) {
    auto it = user_list.find(client_fd);

    if (it != user_list.end()) { // 已连接的用户
        task = [client_fd, &user_list, &event]() {
            UserConnection& user = user_list[client_fd];
            try {
                user.process_request(event);
            } catch (const std::exception& e) {
                std::cerr << "Error processing request from user: " << e.what() << std::endl;
                user.close();
                user_list.erase(it);
            }
        };
        thread_pool.enqueue_task(task); // 异步提交任务到线程池
    } else {
        // 新连接的处理...
    }
}

int main() {
    // 初始化线程池
    ThreadPoolManager thread_pool(thread_num_threads);

    for (/*...*/num_events, ++i) {
        // 如果是主监听套接字事件，接受并分发到线程池
        if (events[i].data.fd == server.server_fd) {
            int client_socket = accept(server.server_fd, NULL, NULL);
            if (client_socket != -1) {
                handle_client_connection(client_socket, events[i], thread_pool);
            } else {
                perror("accept failed");
            }
        } else {
            handle_client_connection(events[i].data.fd, events[i], thread_pool); // 其他已知连接的事件
        }
    }

    return 0;
}

在这里，我们创建了一个`ThreadPoolManager`类，负责维护线程池。当有新的客户端请求时，我们不再立即执行`process_request`，而是通过`enqueue_task`异步地将任务提交给线程池。线程池会在后台自动分配资源来处理这些任务。