#ifndef WEBSOCKETCLIENTWITHPOOL_H
#define WEBSOCKETCLIENTWITHPOOL_H

//#include "WebSocketClient.h"
//#include "ThreadPool.h"
//
//class WebSocketClientPool {
//public:
//    explicit WebSocketClientPool(size_t thread_count);
//    ~WebSocketClientPool();
//
//    // 初始化客户端
//    void init_clients(const std::vector<std::string>& uris);
//
//	// 退出所有客户端
//	void exit_clients();
//
//    // 使用线程池发送消息
//    void post_to_all(const std::string& message);
//    void post_binary_to_all(const std::vector<char>& binary_data);
//
//	// 从池中选择一个空闲的客户端进行发送，不需要服务器响应
//    bool post_to_idle_client(const std::string& message);
//	bool post_binary_to_idle_client(const std::vector<char>& binary_data);
//
//    // 从池中选择一个空闲的客户端进行发送，并需要服务器响应
//	bool send_to_idle_client(const std::string& message, int timeout_ms);
//	bool send_binary_to_idle_client(const std::vector<char>& binary_data, int timeout_ms);
//
//    // 从池中选择一个空闲的客户端进行发送，并等待服务器响应
//    bool send_to_idle_client_and_wait(const std::string& message, int timeout_ms);
//    bool send_binary_to_idle_client_and_wait(const std::vector<char>& binary_data, int timeout_ms);
//
//	// 从池中选择一个空闲的客户端进行发送，并等待服务器响应，如果超时则重试
//	bool send_to_idle_client_with_retry(const std::string& message, int total_timeout_ms, int retry_interval_ms);
//    bool send_binary_to_idle_client_with_retry(std::vector<char>&& binary_data, int total_timeout_ms, int retry_interval_ms);
//
//    // 设置 WebSocket 客户端事件处理程序
//    void set_open_handler(WebSocketClient::OpenHandler handler);
//    void set_message_handler(WebSocketClient::MessageHandler handler);
//    void set_close_handler(WebSocketClient::CloseHandler handler);
//    void set_fail_handler(WebSocketClient::FailHandler handler);
//	void set_pong_handler(WebSocketClient::PongHandler handler);
//
//private:
//    std::vector<std::shared_ptr<WebSocketClient>> m_clients;
//    ThreadPool m_thread_pool;
//};

#endif // WEBSOCKETCLIENTWITHPOOL_H