Сокеты и QThread - как корректно завершить поток

class QManagementClient : public QThread
{
    Q_OBJECT
 
public:
    explicit QManagementClient(QObject* parent = 0);
    virtual ~QManagementClient();
    void send(const QString& message);
    void connectToHost(const QString& hostName, quint16 port);
    void disconnectFromHost();
 
protected:
    void run();
 
signals:
    void connected();
    void disconnected();
 
private:
    bool m_quit;
    quint16 m_port;
    QString m_hostName;
    QMutex m_mutex;
    QTcpSocket* m_socket;
    ManagementProtocol m_protocol;
};
 
QManagementClient::QManagementClient(QObject* parent) : QThread(parent)
{
}
 
QManagementClient::~QManagementClient()
{
    disconnectFromHost();
}
 
void QManagementClient::send(const QString& message)
{
    m_socket->write(message).toLocal8Bit());
}
 
 
void QManagementClient::connectToHost(const QString& hostName, quint16 port)
{
    QMutexLocker locker(&m_mutex);
    m_hostName = hostName;
    m_port = port;
    m_quit = false;
    if (!isRunning())
        start();
}
 
void QManagementClient::run()
{
    m_mutex.lock();
    QString serverName = m_hostName;
    quint16 serverPort = m_port;
    m_mutex.unlock();
 
    m_socket = new QTcpSocket();
    m_socket->connectToHost(serverName, serverPort);
    if (!m_socket->waitForConnected(1000))
    {
        delete m_socket;
        m_socket = 0;
        return;
    }
 
    emit connected();
 
    QString data;
    while (!m_quit)
    {
        if (m_socket->waitForReadyRead())
    {
        // Чего то делаем
    }       
    }
 
    m_socket->disconnectFromHost();
 
    emit disconnected();
 
    delete m_socket;
    m_socket = 0;
}
 
void QManagementClient::disconnectFromHost()
{
    m_mutex.lock();
    m_quit = true;
    m_socket->disconnectFromHost();
    m_mutex.unlock();
 
    wait();
}

class QManagementClient : public QThread
{
    Q_OBJECT
 
public:
    explicit QManagementClient(QObject* parent = 0);
    virtual ~QManagementClient();
    void connectToHost(const QString& hostName, quint16 port);
    void disconnectFromHost();
 
protected:
    void run();
 
signals:
    void connected();
    void disconnected();
 
public slots:
    void readData();
    void onDisconnect();
    void send(const QString& message);
 
private:
    quint16 m_port;
    QString m_hostName;
    QTcpSocket* m_socket;
};
 
QManagementClient::QManagementClient(QObject* parent) : QThread(parent)
{
    moveToThread(this);
}
 
QManagementClient::~QManagementClient()
{
    wait();
}
 
void QManagementClient::send(const QString& message)
{
    m_socket->write(message.toLocal8Bit());
    m_socket->flush();
}
 
void QManagementClient::connectToHost(const QString& hostName, quint16 port)
{
    m_hostName = hostName;
    m_port = port;
 
    if (!isRunning())
        start();
}
 
void QManagementClient::run()
{
    m_socket = new QTcpSocket(this);
    connect(m_socket, SIGNAL(readyRead()), this, SLOT(readData()));
    connect(m_socket, SIGNAL(connected()), this, SIGNAL(connected()));
    connect(m_socket, SIGNAL(disconnected()), this, SLOT(onDisconnect()));
 
    m_socket->connectToHost(m_hostName, m_port);
    if (!m_socket->waitForConnected(1000))
    {
        delete m_socket;
        m_socket = 0;
        return;
    }
 
    emit connected();
 
    exec();
}
 
void QManagementClient::readData()
{
    qDebug() << m_socket->readAll();
}
 
void QManagementClient::onDisconnect()
{
    emit disconnected();
    exit(0);
}
 
void QManagementClient::disconnectFromHost()
{
    m_socket->disconnectFromHost();
}