当前位置: 首页 > article >正文

QT中的线程同步机制

在 Qt 6.8.2(C++)中,两个线程之间的同步可以通过以下机制实现。以下是常用方法及代码示例:

1. ‌QMutex(互斥锁)

用于保护共享资源,确保同一时间只有一个线程访问资源。

 
#include <QMutex>
#include <QThread>

QMutex mutex;
int sharedData = 0;

class WorkerThread : public QThread {
protected:
    void run() override {
        mutex.lock();
        sharedData++;
        mutex.unlock();
    }
};

// 使用 QMutexLocker(更安全,自动管理锁)
void safeIncrement() {
    QMutexLocker locker(&mutex);
    sharedData++;
}

2. ‌QReadWriteLock(读写锁)

允许多个线程同时读取,但写入时独占。

#include <QReadWriteLock>

QReadWriteLock rwLock;
QString sharedString;

class ReaderThread : public QThread {
    void run() override {
        rwLock.lockForRead();
        qDebug() << "Read:" << sharedString;
        rwLock.unlock();
    }
};

class WriterThread : public QThread {
    void run() override {
        rwLock.lockForWrite();
        sharedString = "New Data";
        rwLock.unlock();
    }
};

3. ‌QSemaphore(信号量)

控制对多个相同资源的访问。

#include <QReadWriteLock>

QReadWriteLock rwLock;
QString sharedString;

class ReaderThread : public QThread {
    void run() override {
        rwLock.lockForRead();
        qDebug() << "Read:" << sharedString;
        rwLock.unlock();
    }
};

class WriterThread : public QThread {
    void run() override {
        rwLock.lockForWrite();
        sharedString = "New Data";
        rwLock.unlock();
    }
};

4. ‌QWaitCondition(条件变量)

让线程等待某个条件满足后再执行。

#include <QWaitCondition>
#include <QMutex>

QMutex mutex;
QWaitCondition condition;
bool dataReady = false;

// 生产者线程
void Producer::run() {
    mutex.lock();
    dataReady = true;
    condition.wakeAll(); // 唤醒所有等待线程
    mutex.unlock();
}

// 消费者线程
void Consumer::run() {
    mutex.lock();
    while (!dataReady) {
        condition.wait(&mutex); // 释放mutex并等待
    }
    // 处理数据
    mutex.unlock();
}

5. ‌信号槽跨线程通信

Qt 的信号槽机制默认是线程安全的,可通过 QueuedConnection 实现跨线程通信。

// Worker对象在子线程中执行任务
class Worker : public QObject {
    Q_OBJECT
public slots:
    void doWork() {
        // 耗时操作
        emit resultReady(result);
    }
signals:
    void resultReady(int);
};

// 主线程中
QThread thread;
Worker worker;
worker.moveToThread(&thread);
connect(&worker, &Worker::resultReady, this, &MainWindow::handleResult);
thread.start();

// 触发任务
QMetaObject::invokeMethod(&worker, "doWork", Qt::QueuedConnection);

关键注意事项:

  • 线程亲和性‌:使用 moveToThread() 将对象移动到目标线程,避免直接跨线程访问成员。
  • 避免死锁‌:确保锁的获取和释放成对出现,优先使用 QMutexLocker
  • 跨平台性‌:Qt 的同步机制封装了系统原生 API(如 Windows 的临界区、事件),保证跨平台行为一致。

根据需求选择合适机制:互斥锁适合简单共享资源,信号量控制资源池,条件变量适合复杂等待逻辑,信号槽适合解耦通信。


http://www.kler.cn/a/587864.html

相关文章:

  • 视觉slam十四讲(四)——相机与图像
  • Vue3 + Vite + Yarn + Fabricjs构建的开源演示系统
  • 基于 Verilog 的时序设计:从理论到实践的深度探索
  • 蓝桥杯每日一题01背包拔高·小A点菜
  • Navicat SqlServer 设置自增主键
  • 【人工智能】大语言模型学习大纲
  • 使用 Django 的 `FileResponse` 实现文件下载与在线预览
  • 【虚幻C++笔记】枚举UENUM、结构体USTRUCT
  • 基于CPU使用paddlex OCR识别图片内容
  • 《 线程池项目:线程池背景知识与整体架构梳理》
  • Postman中Authorization和Headers的区别
  • 【软考网工-实践篇】DHCP 动态主机配置协议
  • 【Vue列表渲染中key与数据绑定的核心问题解析】
  • 小程序渲染之谜:如何解决“加载中...”不消失的 Bug(glass-easel)
  • SpringMVC (二)请求处理
  • docker Mysql主从配置
  • 【设计模式】《设计模式:可复用面向对象软件的基础》:设计模式怎样解决设计问题?
  • Vue 系列之:ref、reactive、toRef、toRefs
  • 合并pull request的过程
  • 色彩重生:基于 Retinex 理论的 UR2P-Dehaze 去雾增强器解析