如何将boost io_service用作类变量

问题描述

我看到的所有示例都在这样的主要功能中使用boost::asio：

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,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_,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,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::asio::placeholders::error));
        }
        else
        {
            delete new_session;
        }
    }
    
private:
    boost::asio::io_service& io_service_;
    tcp::acceptor acceptor_;
};

解决方法

暂无找到可以解决该程序问题的有效方法，小编努力寻找整理中！

如果你已经找到好的解决方法，欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@）

boost boost-asio c++