c++ - 如何干净地退出使用 Poco::Net::TCPServer 的程序？

Question

我的服务器启动了一个 Poco::Task，它又启动了两个 TCPServer。

int TBServer::main(const std::vector<std::string>& args) {
  if (!m_helpRequested) {
    TaskManager tm;
    tm.start(new ServerTask());
    waitForTerminationRequest();
    tm.cancelAll();
    tm.joinAll();
  }
  return Application::EXIT_OK;
}

POCO_SERVER_MAIN(TBServer)

任务如下:

void ServerTask::runTask() {

  AutoPtr<PropertyFileConfiguration> pConf;

  try {
    pConf = new PropertyFileConfiguration("TBServer.prop");

    TCPServer local_svr();
    TCPServer remote_svr();

    local_svr.Start(pConf->getInt("local_svr_port", 5000));

    UINT mode = pConf->getInt("svr_mode", 0);

    // Socket mode
    if (mode & 0x01)
      remote_svr.Start(pConf->getInt("remote_svr_port", 8000));

    while(!isCancelled())
    {
      // Do nothing here...the logic is inside the TCPServer classes
      sleep(500);
    }
  }
  catch (Poco::Exception e) {
    log << e.message() << std::endl;
  }
}

此处的TCPServe 类是Poco::Net::TCPServer 的简单包装器。

这里的问题是，当我关闭应用程序时，我遇到了访问冲突，可能是由于以错误的方式终止了 TCPServer 和 TCPConnection。

这是调用堆栈:

  ntdll.dll!_RtlpWaitForCriticalSection@4()  + 0x5b byte    
  ntdll.dll!_RtlEnterCriticalSection@4()  + 0x46 byte   
> TBServer.exe!Poco::MutexImpl::lockImpl()  Riga 76 + 0xc byte  C++
  TBServer.exe!Poco::FastMutex::lock()  Riga 260    C++
  TBServer.exe!Poco::Net::TCPServerDispatcher::release()  Riga 113  C++
  TBServer.exe!Poco::Net::TCPServer::~TCPServer()  Riga 75  C++
  TBServer.exe!Poco::Net::TCPServer::`scalar deleting destructor'()  + 0x2b byte    C++
  TBServer.exe!TCPServer::~TCPServer()  Line 86 + 0x37 byte C++
  TBServer.exe!TCPServer::`scalar deleting destructor'()  + 0x2b byte   C++
  TBServer.exe!Poco::ReleasePolicy<Poco::Net::TCPServerConnectionFactory>::release(Poco::Net::TCPServerConnectionFactory * pObj=0x0141fa8c)  Line 90 + 0x34 byte    C++
  TBServer.exe!Poco::SharedPtr<Poco::Net::TCPServerConnectionFactory,Poco::ReferenceCounter,Poco::ReleasePolicy<Poco::Net::TCPServerConnectionFactory> >::release()  Line 404 + 0xc byte    C++
  TBServer.exe!Poco::SharedPtr<Poco::Net::TCPServerConnectionFactory,Poco::ReferenceCounter,Poco::ReleasePolicy<Poco::Net::TCPServerConnectionFactory> >::~SharedPtr<Poco::Net::TCPServerConnectionFactory,Poco::ReferenceCounter,Poco::ReleasePolicy<Poco::Net::TCPServerConnectionFactory> >()  Line 160  C++
  TBServer.exe!Poco::Net::TCPServerDispatcher::~TCPServerDispatcher()  Line 99 + 0x1a byte  C++
  TBServer.exe!Poco::Net::TCPServerDispatcher::`scalar deleting destructor'()  + 0x2b byte  C++
  TBServer.exe!Poco::Net::TCPServerDispatcher::release()  Line 115 + 0x3a byte  C++
  TBServer.exe!Poco::Net::TCPServer::~TCPServer()  Line 75  C++
  TBServer.exe!Poco::Net::TCPServer::`scalar deleting destructor'()  + 0x2b byte    C++
  TBServer.exe!TCPServer::~TCPServer()  Line 86 + 0x37 byte C++
  TBServer.exe!ServerTask::runTask()  Line 114 + 0xf byte   C++
  TBServer.exe!Poco::Task::run()  Line 85 + 0xf byte    C++
  TBServer.exe!Poco::PooledThread::run()  Line 215 + 0x15 byte  C++
  TBServer.exe!Poco::ThreadImpl::runnableEntry(void * pThread=0x0122089c)  Line 245 + 0x13 byte C++

---

问题

• 如何“等待”所有线程在销毁对象之前结束？

---

测试项目

如果有人愿意检查这种情况，我准备了一个小项目来演示这个问题。可以查到here

Answer 1

解决方案

您需要调用 Poco::Net::TCPServer::stop在退出您的函数范围之前在您的这种类型的实例上，否则它们将无法正确破坏 - 您会得到您发布的诊断。

_{注意:由于您已经有了包装器，请调用 wrapped_server.stop ()在该类型的析构函数中自动处理它。}

---

说明

内部Poco::Net::TCPServer::start创建一个新线程等待并接受传入连接，并且该线程需要时间来清理自身。

只调用析构函数，而不调用 .stop ，这个其他线程将尝试访问不再可用的内存。