使用io_service::run时内存泄漏

Question

我正在尝试编写我的套接字类(下面的代码)。最后，一切都正常工作:重连接、连接、消息发送、消息接收。

但是，当我重复TCPSocketBody::Connect(const：：string &adress，const std::string &port)时，我注意到内存泄漏，例如，如果主机无法访问。我的申请越来越大。

我发现当我移除线条时：

thread_io_service = boost::thread(boost::bind(&boost::asio::io_service::run, &io_service_global));

问题消失了。但我需要这条线。我做错什么了？我检查了我的应用程序中线程的命令行号，它始终是1或2。

#include "TCPSocketBody.h"

TCPSocketBody::TCPSocketBody() : socket_(io_service_global),
                                 resolver(io_service_global),
                                 connected(false),
                                 expectedMessage(0)
{

}

void TCPSocketBody::Close()
{
  io_service_global.post(boost::bind(&TCPSocketBody::DoClose, this));
}

void TCPSocketBody::Connect(const std::string &adress, const std::string &port)
{
    io_service_global.reset();
    iterator = resolver.resolve({adress, port});

     boost::asio::async_connect(socket_, iterator,
           boost::bind(&TCPSocketBody::HandleConnect, this,
           boost::asio::placeholders::error));


     socket_.set_option(boost::asio::ip::tcp::no_delay(true));

     thread_io_service = boost::thread(boost::bind(&boost::asio::io_service::run, &io_service_global));

}

void TCPSocketBody::HandleConnect(const boost::system::error_code& error)
{
  if (!error)
  {           
      connected = true;

      boost::asio::async_read(socket_,
         boost::asio::buffer(data_to_read, MessageCoder::BufferSize()), boost::asio::transfer_all(),
         boost::bind(&TCPSocketBody::HandleReadHeader, this,
           boost::asio::placeholders::error));

  } else
  {
        Close();
  }
}

void TCPSocketBody::HandleReadHeader(const boost::system::error_code& error)
{
    expectedMessage = MessageCoder::HeaderToVal(data_to_read);

    if (expectedMessage > MessageCoder::MaxMessageSize())
    {
       expectedMessage = 0;
       Close();
    } else
    {
        boost::asio::async_read(socket_,
           boost::asio::buffer(data_to_read, expectedMessage), boost::asio::transfer_all(),
           boost::bind(&TCPSocketBody::HandleReadMessage, this,
             boost::asio::placeholders::error));
    }
}

void TCPSocketBody::HandleReadMessage(const boost::system::error_code& error)
{
    expectedMessage = 0;        

    boost::asio::async_read(socket_,
       boost::asio::buffer(data_to_read, MessageCoder::BufferSize()), boost::asio::transfer_all(),
       boost::bind(&TCPSocketBody::HandleReadHeader, this,
         boost::asio::placeholders::error));
}

void TCPSocketBody::WriteMessage(char *dataToSend)
{
    io_service_global.post(boost::bind(&TCPSocketBody::Write, this, dataToSend));
}

void TCPSocketBody::Write(char *dataToSend)
{
    data = dataToSend;

    boost::asio::async_write(socket_,
        boost::asio::buffer(data, std::strlen(data)),
        boost::bind(&TCPSocketBody::HandleWrite, this,
          boost::asio::placeholders::error));

}

void TCPSocketBody::HandleWrite(const boost::system::error_code& error)
{
  if (!error)
  {

  }
  else
  {
        Close();
  }
}

void TCPSocketBody::DoClose()
{
  socket_.close();
  connected = false;
}

Answer 1

没有头文件，很难确定。我怀疑thread_io_service是一个成员变量。对“Connect”的第二个调用将覆盖现有的值，而不会破坏该对象。在对象中分配的任何内存都会泄漏。

也许可以尝试为连接调用中的每个新线程创建thread_io_service和push_back的std：：push_back。当向量被破坏时，它将销毁包含的对象。

瓦兰很可能会用更多的细节来找出这个问题。