Qt 多线程同步之读写锁

我就是我 2022-11-10 00:46 481阅读 0赞

# 1.QReadWriteLock #

使用互斥量时存在一个问题：每次只能有一个线程获得互斥量的权限。如果在一个程序中有多个线程读取某个变量，使用互斥量时也必须排队。而实际上若只是读取一个变量，是可以让多个线程同时访问的，这样互斥量就会降低程序的性能。

*  lockForRead()：以只读方式锁定资源，如果有其他线程以写入方式锁定，这个函数会阻塞。
 *  lockForWrite()：以写入方式锁定资源，如果本线程或其他线程以读或写模式锁定资源，这个函数会阻塞。
 *  unlock()：解锁。
 *  tryLockForRead()：是lockForRead()的非阻塞版本。
 *  tryLockForWrite()：是lockForWrite()的非阻塞版本。

# 2.示例 #

假设有一个数据采集程序。

*  线程一负责采集数据到缓冲区
 *  线程二负责读取缓冲区的数据并显示
 *  线程三负责读取缓冲区的数据并保存到文件

int buffer[100];
    QReadWriteLock lock;
    
    void threadWriteToBuffer::run()
    {
        ...
        lock.lockForWrite();
        writeToBuffer();    //数据写入buffer
        lock.unlock();
        ...
    }
    
    void threadShow::run()
    {
        ...
        lock.lockForRead();
        showBuffer();   //读取buffer数据并显示
        lock.unlock();
        ...
    }
    
    void threadSaveFile::run()
    {
        ...
        lock.lockForRead();
        saveFile();   //读取buffer数据并保存到文件
        lock.unlock();
        ...
    }

**QReadLocker和QWriteLocker是QReadWriteLock的简便形式，如同QMutexLocker是QMutex的简便版本一样，无需与unlock配对使用，以上代码可以改成这样。**

int buffer[100];
    QReadWriteLock lock;
    
    void threadWriteToBuffer::run()
    {
        ...
        QWriteLocker locker(&lock);
        writeToBuffer();    //数据写入buffer
        ...
    }
    
    void threadShow::run()
    {
        ...
        QReadLocker locker(&lock);
        showBuffer();   //读取buffer数据并显示
        ...
    }
    
    void threadSaveFile::run()
    {
        ...
        QReadLocker locker(&lock);
        saveFile();   //读取buffer数据并保存到文件
        ...
    }