我正在使用boost实现一些asio操作,
我遇到了接口(interface)问题,在初始化时没有收到“处理程序”,但是之后,
这迫使我编写一个“忙”循环,我想做的是即使没有至少一个处理程序也要运行io_service,这可能吗?如何处理呢?等待服务上的处理程序吗?
这是我的代码。
/** : */
void Run () { while(true) {m_srv.run(); Sleep(1);} } // once 1 handler is inside service, thread will not be in busy loop
private: // members:
io_service m_srv;
有什么建议么?谢谢
这是代码问题:(m_drv是操作boost::thread(io_service::run ..)的任务)
class App : public Base::Application
{
public:
/** : */
App(char* name, char* id) : Application(name, id), m_drv("NetTask"), m_worker("Worker"), m_acceptor(m_worker, Drv(), &OnAccept, 4567)
{
m_acceptor.Accept(Drv());
}
/** : */
inline DriverImp& Drv() { return static_cast<DriverImp&>(m_drv.Imp());}
/** : */
inline Reactor& Worker() { return m_worker; }
public:
APTR(Socket) m_sock;
private: // members:
Driver m_drv;
Reactor m_worker;
Acceptor m_acceptor;
};
最佳答案
您需要使用io_service::work:
boost::asio::io_service service;
boost::asio::io_service::work work( service );
注意:在析构函数中,
work
对象通知service
工作已完成,并且io_service::run()
可能返回。