调用 movetothread() 后如何停止 Qthread？

Question

当我重新实现 QTcpserver::incomingConnection() 时，会创建一个新的 QThread 和一个新的 QTcpsocket。accept-fd 被传递给 QTcpsocket。但是，整个过程意外退出时会出现警告： QThread：在线程仍在运行时被销毁 当 Qthread 调用 quit() 时，这两个对象将被删除。这是下面的代码。

 void TcpServer::incomingConnection(qintptr handle)
{
    QThread* tcpThread = new QThread;
    TcpSocket* tcpSocket = new TcpSocket;

    tcpSocket->setSocketDescriptor(handle);
    tcpSocket->moveToThread(tcpThread);

    connect(tcpSocket,&TcpSocket::sigRecvFinish, [=](){
        tcpThread->quit();
        delete tcpSocket;
        delete tcpThread;
    });
    tcpThread->start();
}

如何退出线程并正确释放资源？同时，是什么导致了这个问题？ 如果您能帮助我解决这个问题，我将不胜感激。

Answer 1

首先，Qt 有很好的异步 API，因此使用线程（在这种情况下）完全过时并且浪费资源。

通过在连接语句中使用 lambda，您失去了线程跳跃功能，这是由 connect 默认完成的。结果是您试图从该对象管理的线程中销毁线程对象。

请注意，QObject::connect 最后一个参数是：Qt::ConnectionType type = Qt::AutoConnection（没有 lambda 的连接）。当使用 lambda 时，QObject::connect 没有这样的功能，代码是从调用信号的线程调用的。

删除 lambda 将确保每次调用都在正确的线程上完成。

void TcpServer::incomingConnection(qintptr handle)
{
    QThread* tcpThread = new QThread;
    TcpSocket* tcpSocket = new TcpSocket;

    tcpSocket->setSocketDescriptor(handle);
    tcpSocket->moveToThread(tcpThread);

    connect(tcpSocket, &TcpSocket::sigRecvFinish, tcpSocket, &QBject::delteLater);
    connect(tcpSocket, &TcpSocket::sigRecvFinish, tcpThread, &QThread::quit);
    connect( tcpThread, &QThread::finished, tcpThread, &QThread::deleteLater );

    tcpThread->start();
}

技术细节见：

Qt Namespace | Qt Core 5.15.3

Constant	Value	Description
Qt::AutoConnection	0	(Default) If the receiver lives in the thread that emits the signal, Qt::DirectConnection is used. Otherwise, Qt::QueuedConnection is used. The connection type is determined when the signal is emitted.

Answer 2

您需要将您的connect 替换为以下代码：

connect( tcpSocket, &TcpSocket::sigRecvFinish, tcpSocket, &QObject::deleteLater );
connect( tcpSocket, &QObject::destroyed, tcpThread, &QThread::quit );
connect( tcpThread, &QThread::finished, tcpThread, &QThread::deleteLater );