boost::asio::io_service.post() 后台线程内存使用

Question

我想在后台线程中运行 boost::asio::io_service.run()。所以当我需要它时 post() func into.

这是主要功能：

int main(int /*argc*/, char** /*argv*/)
{
    std::string message = "hello";

    logg = new logger_client(filename,ip,13666);
    logg->start();

    while (true)
        logg->add_string(message);

    return 0;
}

以及来自logger_client的一些相关函数：

std::auto_ptr<boost::asio::io_service::work> work;

logger_client::logger_client(std::string& filename,std::string& ip, uint16_t port) : work(new boost::asio::io_service::work(io_service))
{
}

void logger_client::start()
{
    ios_thread = new boost::thread(boost::bind(&io_service.run,&io_service));
}

void print_nothing()
{
    printf("%s\n","lie");
}

void logger_client::add_string(std::string& message)
{
    io_service.post(boost::bind(print_nothing));
    //io_service.post(strand->wrap(boost::bind(&logger_client::add_string_imp,this,message)));
    //io_service.run();
}

当我运行这样做时，我的程序不到一分钟就吃掉了 2Gb。如果我删除无尽的工作并更改为：

void logger_client::add_string(std::string& message)
{
    io_service.post(boost::bind(print_nothing));
    //io_service.post(strand->wrap(boost::bind(&logger_client::add_string_imp,this,message)));
    io_service.run();
}

程序运行良好。但我不想在此（主）线程上调用异步操作。我做错了什么？

更新

我在 while(true) 循环中添加了 sleep(1sec)，内存不再增长。但这不是解决方案。因为如果我在 post() 之后调用运行() （即使用主线程处理句柄），甚至再添加五个带有 while(true) 循环的线程，内存就不会增长。那么为什么主线程比新创建的线程好这么多呢？我还尝试了 io_service::run 的线程池 - 没有帮助。

Answer 1

io_service.run 将退出除非有待处理的操作。

因此，您的 ios_thread 将立即退出。

解决方法是使用io_service::work.

此外，像这样的无限循环垃圾邮件

 while (true)
        logg->add_string(message);

这不是一个好主意，也许可以添加一些 sleep()，以减慢它的速度并使其处于受控状态。

boost::asio::io_service.post() 后台线程内存使用

boost::asio::io_service.post() background thread memory usage

c++

boost-thread

boost-asio