五、监听线程的实现
监听线程需要有一个MySocketServer来监听客户端的连接,每当形成一个新的连接,查看是否超过设置的最大连接数,如果超过则关闭连接,如果未超过设置的最大连接数,则形成一个新的MyConnection,将其加入连接池和线程池。
MySocketServer *pServer = new MySocketServer(port);
MyConnectionPool *pPool = new MyConnectionPool();
while (!stopFlag)
{
MySocket * sock = pServer->acceptConnection(5);
if(sock != null)
{
if(m_connections.size > maxConnectionSize)
{
sock.close();
}
MyTask *pTask = new MyConnection();
pPool->addConnection(pTask);
}
}
本文导航
- 第1页: 首页
- 第2页: 对Socket的封装
- 第3页: 线程池的实现
- 第4页: 连接池的实现
- 第5页: 监听线程的实现