Qt多线程同步的几种实现方式
1. 互斥量:QMutex QMutex类提供的是线程之间的访问顺序化。QMutex的目的是保护一个对象/数据结构或者代码段在同一时间只有一个线程可以访问。基本使用方法如下: QMutex mutex; int var; void function() { mutex.lock(); // 访问var var * var; mutex.unlock(); } 如果使用mutex加锁,却没有使用unlock解锁,那么就会造成死锁,其他线程永远也得不到访问变量的机会,所以为了解决这个问题,Qt引入了QMutexLocker类,二者直接可以配合使用更加方便简洁,示例如下: QMutex mutex; int var; void function() { QMutextLocker locker(&mutex); // 访问var var * var; }
2. QReadWriteLock QMutex只允许某个时刻有一个线程对共享资源进行访问,如果需要多个线程对共享资源进行读访问,同时只有一个线程进行写访问,这种情况下就可以使用QReadWriteLock。QReadWriteLock主要实现多个线程读资源,一个线程写。写线程执行的时候会阻塞所有的读线程,而读线程之间的运行不需要进行同步。使用示例如下: int var; QReadWriteLock lock; void function() { lock.lockForRead(); int x = var; lock.unlock(); } void function2() { lock.lockForWrite(); var = 100; lock.unlock(); } 和QMutexLocker一样,Qt同样提供了QReadLocker和QWriteLocker。 int var; QReadWriteLock lock; void fun() { QReadLocker(&lock); int x = var; } void fun2() { QWriteLocker(&lock); var = 1000; }
3. QSemaphore QSemaphore是QMutex的一般化,它可以保护一定数量的相同资源,而QMutex只能保护一个资源。信号量比互斥量具有更好的并发性,我们可以利用信号量实现生产者-消费者模式,如下所示: const int dataSize = 100000; const int bufferSize = 1024; char buffer[bufferSize]; QSemaphore freeBytes(bufferSize); QSemaphore usedButes; void Producer::run() { for (int i = 0; i < dataSize; ++i) { freeBytes.acquire(); buffer[i % bufferSize] = i; usedBytes.release(); } } void Consumer::run() { for (int i = 0; i < dataSize; ++i) { usedBytes.acquire(); qDebug() << buffer[i % bufferSize]; freeBytes.release(); } }
更多关于物联网培训的问题,欢迎咨询千锋教育在线名师。千锋教育拥有多年IT培训服务经验,采用全程面授高品质、高体验培养模式,拥有国内一体化教学管理及学员服务,助力更多学员实现高薪梦想。