c++ - 如何使用 boost io_service 作为类变量

Question

我见过的所有示例都boost::asio在 main 函数中使用，如下所示：

int main()
{
    boost::asio::io_service io_service;
    server server1(io_service, 1980);   
    boost::thread t(boost::bind(&io_service::run, &io_service));
    
    return 0;
}

如何将它们用作类变量？

class TcpConnect
{
private:
    boost::asio::io_service io_service;
    server server1;
    boost::thread t;

    void initBoost() // I want to create a boost thread in this function
}

这是服务器文件定义：

class session
{
public:
    session(boost::asio::io_service& io_service)
        : socket_(io_service)
    {
    }
    
    tcp::socket& socket()
    {
        return socket_;
    }
    
    void start()
    {
        socket_.async_read_some(boost::asio::buffer(data_, max_length),
            boost::bind(&session::handle_read, this,
                boost::asio::placeholders::error,
            boost::asio::placeholders::bytes_transferred));
    }
    
    void handle_read(const boost::system::error_code& error,
        size_t bytes_transferred)
    {
        if (!error)
        {
            boost::asio::async_write(socket_,
                boost::asio::buffer(data_, bytes_transferred),
                boost::bind(&session::handle_write, this,
                boost::asio::placeholders::error));
        }
        else
        {
            delete this;
        }
    }
    
    void handle_write(const boost::system::error_code& error)
    {
        if (!error)
        {
            socket_.async_read_some(boost::asio::buffer(data_, max_length),
                boost::bind(&session::handle_read, this,
                    boost::asio::placeholders::error,
                    boost::asio::placeholders::bytes_transferred));
        }
        else
        {
            delete this;
        }
    }
    
private:
    tcp::socket socket_;
    enum { max_length = 1024 };
    char data_[max_length];
};
    
class server
{
public:
    server(boost::asio::io_service& io_service, short port)
        : io_service_(io_service),
        acceptor_(io_service, tcp::endpoint(tcp::v4(), port))
    {
        session* new_session = new session(io_service_);
        acceptor_.async_accept(new_session->socket(),
            boost::bind(&server::handle_accept, this, new_session,
                boost::asio::placeholders::error));
    }
    
    void handle_accept(session* new_session,
        const boost::system::error_code& error)
    {
        if (!error)
        {
            new_session->start();
            new_session = new session(io_service_);
            acceptor_.async_accept(new_session->socket(),
                boost::bind(&server::handle_accept, this, new_session,
                    boost::asio::placeholders::error));
        }
        else
        {
            delete new_session;
        }
    }
    
private:
    boost::asio::io_service& io_service_;
    tcp::acceptor acceptor_;
};

标签： c++boostboost-asio