重点:
1.互斥量:QMutex配套使用,lock(),unlock(),如果一个线程准备读取另一个线程数据时候采用tryLock()去锁定互斥量,保证数据完整性。
QMutexLocker简化版的QMutex,在范围区域内使用。
QMutex mutex
QMutexLocker locker(&mutex);
2.读写锁:QReadWriteLock配套使用,lockForWrite(),lockForRead(),它允许多个线程以只读方式同步访问资源,但只要有一个线程以写入方式访问资源,其他线程就必须等待,直到写操作完成。QReadLocker和QWriteLocker是简化版的QReadWriteLock,
QReadWriteLock mutex;
QReadLocker locker(&mutex);
QWriteLocker locker(&mutex);
3.基于条件等待的线程同步:QWaitCondition通过与QMutex或者QReadWriteLock结合使用。
通过wakeAll()和wait()方法处理。 一旦读完一个数据,就通过wakeAll()唤醒等待的线程。
这里需要注意线程中传值的时候,在主线程和子线程中,通过信号与槽发送QString,遇到
QObject::connect: Cannot queue arguments of type 'QString&'问题
原因
不允许跨线程传递非const应用。
解决方法
就是要么是const引用,要么是值传递
4.基于信号量的线程同步:QSemaphore是一种限制对共享资源进行访问的ITC技术。互斥量只能被锁定一次,而信号量可以用多次。互斥量相当于列车上的卫生间,一次只能一个人使用,信号量则是多人公共厕所。n个资源就是信号量要保护的资源,资源怎么分配,看内部处理。
需要特别注意的是,两个线程之间因为两个信号量存在耦合,在线程结束不要使用threadA->terminate(); //强制结束线程
if (threadA->isRunning())
{
threadA->terminate(); //强制结束线程
threadA->wait(); //等待线程结束
}
而要使用,否则重新启动线程会出问题。
if (threadDAQ->isRunning())
threadDAQ->stopThread(); //结束线程