带有boost::asio的ThreadPool不会退出

ThreadPool with boost::asio does not quit?

本文关键字：ThreadPool 退出 boost asio 带有      更新时间：2023-10-16

我有以下用boost:：asio创建的线程池的最小示例。

#include <queue>
#include <map>
#include <boost/shared_ptr.hpp>
#include <boost/asio/io_service.hpp>
#include <boost/thread/thread.hpp>
#include <boost/asio.hpp>
#include <boost/date_time/posix_time/posix_time.hpp> // remove me (only for io)
class ThreadPool
{
public:
    void work_as_mainthread(void) { m_io_service.run(); }
    ThreadPool(int poolSize = 4) : timer(m_io_service)
    {
        timer.expires_from_now(boost::posix_time::seconds(1)); // this line does not affect the problem
        m_pWork.reset( new boost::asio::io_service::work(m_io_service) );
        for ( int i = 0; i < poolSize; ++i)
            m_threadGroup.create_thread( boost::bind(&boost::asio::io_service::run, &m_io_service) );
    }
    ~ThreadPool()
    {
        m_pWork.reset();
        m_threadGroup.join_all();
    }
private:
    boost::asio::io_service m_io_service;
    boost::asio::deadline_timer timer;
    boost::shared_ptr<boost::asio::io_service::work> m_pWork;
    boost::thread_group m_threadGroup;
};
int main()
{
    int n_threads = 2;
    ThreadPool pool(n_threads);
    pool.work_as_mainthread();
    // this line is never reached...
    return 0;
}

如果你喜欢，你可以这样编译：

g++ -Wall -g -lboost_thread -lboost_date_time -lboost_system main.cpp -o main

让我感到奇怪的是，这个程序没有停止。我所做的是调用io_service:：run，但没有任何"工作"。正如boost:：asio文档中所说，没有工作的io_services会自行退出。为什么我的程序从不退出？

创建boost::asio::io_service::work对象时，会阻止io_service完成。

// This line keeps the io_service running
m_pWork.reset( new boost::asio::io_service::work(m_io_service) );

如果你想让它停止，你需要销毁这个工作对象，比如：

// stop the worker(s)
m_pWork.reset();

这取决于你找到一个合适的时间/地点来做这件事。我建议调用timer.async_wait()，然后在处理程序中重置工作对象，看看这一切应该如何协同工作。

请参阅本部分文档。

相关文章：