为什么需要多线程

在开发存在界面交互的程序中，为了使一些耗时操作不造成卡顿；我们一般会将这些耗时操作放到子线程中进行处理，常见的如一些同步通讯。

虽然已编写过几次多线程的程序，但是每次使用都感觉心里不踏实，借用 QThread 总结一下罢。

QThread使用方法

Qt 中使用多线程，必然绕不开的是 QThread。建议先过一遍 QThread Class 文档。

文档中演示了两种使用方法：

new QThread Class & Override run()

/*------------------------------WorkerThread-----------------------------------*/
class WorkerThread : public QThread
{
   
    
    Q_OBJECT
public:
    explicit WorkerThread();
protected:
    void run();
signals:
    void resultReady(const QString &s);
};

void WorkerThread::run(){
   
    
    /* ... here is the expensive or blocking operation ... */
}

/*------------------------------MainWindow-----------------------------------*/
void MainWindow::startWorkInAThread()
{
   
    
    WorkerThread *workerThread = new WorkerThread();
    // Release object in workerThread
    connect(workerThread, &WorkerThread::finished, workerThread, &QObject::deleteLater);
    workerThread->start();
}

需要 注意 的：

• run() 中未调用 exec() 开启 even loop，那么在 run() 执行结束时，线程将自动退出。

• 该案例中，WorkerThread 存在于实例化它的旧线程中，仅有 run() 中是在子线程中执行的。我们可以通过以下代码 打印线程ID 进行验证：

  qDebug()<<"mythread QThread::currentThreadId()==" << QThread::currentThreadId();
  

这就存在一个尴尬的问题，如果在 WorkerThread 的 run() 中使用了 WorkerThread 的成员变量，而且 QThread的其他方法也使用到了它，即我们从不同线程访问该成员变量，这时需要自行检查这样是否安全。

这个例子也说明了，QThread 实例本身并不是一个线程，正如 QThread Class 开篇点明这是一个 线程管理类 。

The QThread class provides a platform-independent way to manage threads.

注意：这种使用方法并不推荐，至于它为什么仍然出现在 QThread的文档里作为案例 “误导” 我们，这貌似是个历史问题。

在 Qt 4.4 版本以前的 QThread 类是个抽象类，要想编写多线程代码唯一的做法就是 继承 QThread 类。该论断在 Qt4.3 的 QThread Class 中可以印证。

但是之后的版本中，Qt 库完善了线程的亲和性以及信号槽机制，我们有了更为优雅的使用线程的方式，即 QObject::moveToThread() 。但是即使在 2020 的今天，网上仍然有不少教程教我们使用Qt多线程的旧方法；难怪 Bradley T. Hughes 在 2010 专门写了篇 You’re doing it wrong…，为此我只能表示：

new Object Class & moveToThread(new QThread)

下面介绍推荐做法。

/*--------------------DisconnectMonitor-------------------------*/
class DisconnectMonitor : public QObject
{
   
    
    Q_OBJECT

public:
    explicit DisconnectMonitor();

signals:
    void StartMonitor(long long hanlde);
    void StopMonitor();
	// if Controller disconnect emit this signal
    void Disconnect();

private slots:
    void slot_StartMonitor(long long hanlde);
    void slot_StopMonitor();
	// State machine
    void Monitor();

private:
    long long ControllerHanlde;
    QTimer *MonitorTimer;
};

DisconnectMonitor::DisconnectMonitor()
{
   
    
	// New a Timer monitor controller by timing
    MonitorTimer = new QTimer;

	ControllerHanlde = 0;

    connect(MonitorTimer,&QTimer::timeout,this,&DisconnectMonitor::Monitor);
    connect(this,&DisconnectMonitor::StartMonitor,this,&DisconnectMonitor::slot_StartMonitor);
    connect(this,&DisconnectMonitor::StopMonitor,this,&DisconnectMonitor::slot_StopMonitor);

    MonitorTimer->start(TAKETIME);
}

void DisconnectMonitor::Monitor(){
   
    

	// if not Controller -> return
    if(0 == ControllerHanlde){
   
    
        return;
    }
	//else Listening