diff --git a/servant/libservant/ServantProxy.cpp b/servant/libservant/ServantProxy.cpp index 548362d..aaa2de1 100644 --- a/servant/libservant/ServantProxy.cpp +++ b/servant/libservant/ServantProxy.cpp @@ -1560,6 +1560,11 @@ void ServantProxy::selectNetThreadInfo(ServantProxyThreadData *pSptd, ObjectProx } } + if(communicatorEpollInfo->_communicator->isTerminating()) + { + throw TarsCommunicatorException("communicator may deconstruct"); + } + assert(communicatorEpollInfo->_netSeq < _communicator->getCommunicatorEpollNum()); //循环使用下一个网络线程发送数据