#include "widget.h"
#include "ui_widget.h"

Widget::Widget(QWidget *parent) :
    QWidget(parent),
    ui(new Ui::Widget)
{
    ui->setupUi(this);
    SocketThread *worker = new SocketThread;
    worker->moveToThread(&workerThread);
    connect(&workerThread, &QThread::finished, worker, &QObject::deleteLater);
    connect(this, &Widget::operate, worker, &SocketThread::run1);
    connect(worker, &SocketThread::resultReady, this, &Widget::handleResults);
    workerThread.start();
    emit operate();
    qDebug()<<"main"<<QThread::currentThreadId();
}

Widget::~Widget()
{
    //t.exit();
    workerThread.quit();
    workerThread.wait();
    delete ui;
}

void Widget::handleResults(const QString &)
{

}
 

#ifndefWIDGET_H

#defineWIDGET_H

#include<QWidget>

#include"socketthread.h"

#include<QThread>

namespaceUi{

classWidget;

}

classWidget:publicQWidget

{

Q_OBJECT

public:

explicitWidget(QWidget*parent=0);

~Widget();

private:

Ui::Widget*ui;

QThreadworkerThread;

publicslots:

voidhandleResults(constQString&);

signals
 
:

voidoperate();

};

#endif//WIDGET_H

#include"socketthread.h"

#include"QDebug"

#include<QMessageBox>

#include<QThread>

SocketThread::SocketThread(QObject*parent):QObject(parent)

{

//start();

}

SocketThread::~SocketThread()

{

//quit();

//wait();

}

voidSocketThread::OnNewConnection()

{

qDebug()<<"newconnection"
 
;

socket_ptr=std::make_shared<QTcpSocket>();

socket_ptr=static_cast<std::shared_ptr<QTcpSocket>>(server_ptr->nextPendingConnection());

connect(socket_ptr.get(),QTcpSocket::readyRead,this,OnRead);

socket_list->push_back(socket_ptr);

qDebug()<<QThread::currentThreadId();

}

voidSocketThread::OnRead()

{

qDebug()<<"readyread";

qDebug()<<QThread::currentThreadId();

QByteArrayarr;

QTcpSocket*socket_ptr=static_cast<QTcpSocket*>(sender());

arr=socket_ptr->readAll();

socket_ptr->write(arr);

qDebug()<<arr;

}

voidSocketThread::run1()

{

socket_list=newstd::list<std::shared_ptr<QTcpSocket>>();

server_ptr=std::make_shared<QTcpServer>();

server_ptr->listen(QHostAddress::Any,5000);

connect(server_ptr.get(),QTcpServer::newConnection,\

this,SocketThread::OnNewConnection);

qDebug()<<QThread::currentThreadId();

}

#ifndefSOCKETTHREAD_H

#defineSOCKETTHREAD_H

#include<QObject>

#include<QTcpSocket>

#include<QTcpServer>

#include<memory>

#include<list>

classSocketThread:publicQObject

{

Q_OBJECT

public:

explicitSocketThread(QObject*parent=0);

~SocketThread();

signals:

publicslots:

voidOnNewConnection();

voidOnRead();

publicslots:

voidrun1();

private:

std::list<std::shared_ptr<QTcpSocket>>*socket_list;

std::shared_ptr<QTcpSocket>socket_ptr;

std::shared_ptr<QTcpServer>server_ptr;

signals:

voidresultReady(constQString&result);

};

#endif//SOCKETTHREAD_H