0

我现在编写游戏服务器,这是我的 onReadable 函数:

void CSConnection::onReadable(const AutoPtr<ReadableNotification>& pNf)
{
    try
    {
        char * rbuff = new char[128](); //allocate incoming packet memory
        int n = _socket.receiveBytes(rbuff, 128);
        if(n > 8)
        {
            WorkerThreadPool::getInstance().tp->start(*new LogicHandler(*this, rbuff));
        }
        else
        {
            delete rbuff;
            delete this;
        }
    }
    catch(Poco::Exception& exc)
    {
        app.logger().log(exc);
        delete this;
    }
}

我试图在线程池的逻辑处理程序中移动读取数据包,但通知称为乘法。

有没有办法只得到一个通知?因为在线程中读取速度较慢,并且它会调用 5-9 次 onReadable。谢谢。

4

0 回答 0