QT线程同步误区：全局的互斥量QMutex

女爷i 2022-02-27 19:08 455阅读 0赞

**线程同步**：Qt中使用多线程时候，多线程的同步就是一个不可避免的问题。  
多线程的同步就是使多个线程在同时执行同一段代码的时候，有顺序的执行,不会出现同时有两个或者多个线程执行同一段代码的情况，特别是在对变量或者文件执行写操作的时候。也就是所谓的线程安全，线程安全指的是这段代码在一个线程或者多个线程执行的过程中，不加同步机制或者任何其他代码，执行的结果是一样的，这就是线程安全。  
在Qt中常用的同步方法是使用锁机制，但是如果使用的方法不对或者时机不对同样也不会起到线程同步的效果。  
例如： 有两个进程都对一个变量进行读写操作，这时就需要互斥量来进行线程同步，这个**互斥量必须是全局**的，不然如果各自在.cpp中声明一个QMutex mutex;是没有任何意义的。因为：每个线程对象都创建了一个QMutex对象，两个线程在运行过程中各自执行的是自己的锁，所以每个锁有且只有一个线程在执行。它们是互不干扰的，所有虽然加锁了，也没有起到同步的作用。

程序功能：  
线程1：每五秒读写一次全部变量globalCount  
线程2：每1秒读写一次全部变量globalCount  
下面程序的实验现象是：  
当线程1在读写数据时，线程2会阻塞住（大概5s）等线程1释放锁才能使用  
当线程2在读写数据时，线程1会阻塞住（大概1s）等线程2释放锁才能使用  
![在这里插入图片描述][20190328113145910.png]  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3p5NDc2NzU2NzY_size_16_color_FFFFFF_t_70]

//线程1：MyThread.cpp

#include "mythread.h"
    #include <QMutex>
    
    QMutex mutex;
    extern int globalCount ;
    
    MyThread::MyThread()
    {
        isStop = true;
    }
    
    void MyThread::closeThread()
    {
        isStop = true;
    }
    //重写基类的run函数
    void MyThread::run()//只有run()里面在新的线程里
    {
        qDebug()<<tr("mythread QThread::currentThreadId()==")<<QThread::currentThreadId();
        isStop = false;
    
    //这种方式还是相当于在主线程里面执行
    //    timer= new QTimer(NULL);
    //    connect(timer, SIGNAL(timeout()), this, SLOT(onTimeout()));
    //    timer->start(1000);
    //    this->exec();
        while(1)
        {
            if(isStop)
            {
                return;
            }
    
            QMutexLocker locker(&mutex);
            qDebug()<<"globalCount: " << ++globalCount <<QThread::currentThreadId();
    
            sleep(5);//QThread
        }
    }
    
    //这种方式还是相当于在主线程里面执行
    void MyThread::onTimeout()
    {
        qDebug()<<tr("mythread QThread::currentThreadId()==")<<QThread::currentThreadId();
        qDebug()<<"globalCount: " << ++globalCount;
    
    }

//线程2：MyThread1.cpp

#include "mythread1.h"
    #include <QMutex>
    
    extern QMutex mutex;
    QMutex mutex1;
    extern int globalCount ;
    
    MyThread1::MyThread1(QObject *parent) : QObject(parent)
    {
        isStop = true;
    }
    
    void MyThread1::closeThread()
    {
        isStop = true;
    }
    
    void MyThread1::doWork()
    {
        qDebug()<<tr("mythread2 QThread::currentThreadId()==")<<QThread::currentThreadId();
        isStop = false;
    
        //定时方式1:(都是在子线程中)
        timer= new QTimer(this);
        connect(timer, SIGNAL(timeout()), this, SLOT(onTimeout()));
        timer->start(1000);
    
        //定时方式2:(都是在子线程中)
    //    while(1)
    //    {
    //        if(isStop)
    //        {
    //            return;
    //        }
    
    //        QMutexLocker locker(&mutex);
    //        qDebug()<<"globalCount: " << ++globalCount <<QThread::currentThreadId();
    
    //        Sleep(1000);//<windows.h>,大写的S,单位是微秒
    //    }
    }
    
    void MyThread1::onTimeout()
    {
        QMutexLocker locker(&mutex);
        qDebug()<<"globalCount: " << ++globalCount <<QThread::currentThreadId();
    
    }

[20190328113145910.png]: /images/20220227/24062b0412b84970afdf214cf8f56b5e.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3p5NDc2NzU2NzY_size_16_color_FFFFFF_t_70]: /images/20220227/73c0cc460b3b46db9ff26f3e6be0352a.png