libev win下不启用

Author: 渡世白玉

Server/tcpsocket.cpp

@@ -10,6 +10,7 @@ TcpSocket::TcpSocket(qintptr socketDescriptor, QObject *parent) : //构造函数
     connect(this,&TcpSocket::readyRead,this,&TcpSocket::readData);
     dis = connect(this,&TcpSocket::disconnected,
         [&](){
+            qDebug() << "disconnect" ;
             emit sockDisConnect(socketID,this->peerAddress().toString(),this->peerPort(),QThread::currentThread());//发送断开连接的用户信息
             this->deleteLater();
         });
@@ -47,13 +48,14 @@ void TcpSocket::disConTcp(int i)
 
 void TcpSocket::readData()
 {
-    datas.append(this->readAll());
-//       auto data  = handleData(this->readAll(),this->peerAddress().toString(),this->peerPort());
-//       this->write(data);
-    if (!watcher.isRunning())//放到异步线程中处理。
-    {
-        watcher.setFuture(QtConcurrent::run(this,&TcpSocket::handleData,datas.dequeue(),this->peerAddress().toString(),this->peerPort()));
-    }
+//    datas.append(this->readAll());
+    auto data  = handleData(this->readAll(),this->peerAddress().toString(),this->peerPort());
+    qDebug() << data;
+    this->write(data);
+//    if (!watcher.isRunning())//放到异步线程中处理。
+//    {
+//        watcher.setFuture(QtConcurrent::run(this,&TcpSocket::handleData,datas.dequeue(),this->peerAddress().toString(),this->peerPort()));
+//    }
 }
 
 QByteArray TcpSocket::handleData(QByteArray data, const QString &ip, qint16 port)

Server/threadhandle.h

@@ -22,7 +22,7 @@ class ThreadHandle
     static ThreadHandle & getClass(); //返回对象引用，是单例类
 
     QThread * getThread(); //取出应该移入的线程
-    void initThreadType(ThreadType type = HANDLESIZE,unsigned int max = 10);//初始化线程管理的方式
+    void initThreadType(ThreadType type = HANDLESIZE,unsigned int max = 1000);//初始化线程管理的方式
     void removeThread(QThread *);//连接断开，线程计数减一
     void clear();//清空计数