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

Question

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

这是主要功能：

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() 之后调用 run() （即使用主线程处理句柄），甚至使用 while(true) 循环再添加五个线程，内存不会增长。那么为什么主线程比新创建的要好很多呢？我还尝试了 io_service::run 的线程池 - 没有帮助。

Answer 1

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

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

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

另外，这样的死循环垃圾邮件

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

这不是一个好主意，也许添加一些 sleep() 来减慢它的速度并控制它。