如何干净退出正在使用Poco :: Net :: TCPServer的程序？

Question

如何干净退出正在使用Poco :: Net :: TCPServer的程序？

5

我的服务器启动一个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++

问题

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

测试项目

如果有人想要检查这个情况，我准备了一个小项目来演示这个问题。可以在这里找到。

- Barzo

你使用的 Poco 版本是什么？ - Filip Roséen - refp

我正在使用Poco v1.5.2-all。 - Barzo

1个回答

网页内容由stack overflow 提供, 点击上面的

可以查看英文原文，
原文链接

- Filip Roséen - refp · Accepted Answer

解决方案

在退出函数作用域之前，您需要调用Poco::Net::TCPServer::stop来停止此类型的实例，否则它们将无法正确销毁 - 并且您会得到您发布的诊断信息。

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

说明

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

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