Qt多线程概述.doc

Qt多线程概述
Qt线程类
Qt包含下面一些线程相关的类:
QThread提供了开始一个新线程的方法
QThreadStorage提供逐线程数据存储
QMutex提供相互排斥的锁,或互斥量
QMutexLocker是一个便利类,它可以自动对QMutex加锁与解锁
QReadWriterLock提供了一个可以同时读操作的锁
QReadLocker与QWriteLocker是便利类,它自动对QReadWriteLock加锁与解锁
QSemaphore提供了一个整型信号量,是互斥量的泛化
QWaitCondition提供了一种方法,使得线程可以在被另外线程唤醒之前一直休眠。
Qt线程的创建
Qt线程中有一个公共的抽象类,所有的线程都是从这个QThread抽象类中派生的,要实现QThread中的纯虚函数run(),run()函数是通过start()函数来实现调用的。
1 class MyThread:public QThread{
2 public 3virtual void run();
4};
5 6void MyThread:run()
7{
8 for int count=0;count 20;count++){
9 sleep(1);
10 qDebug("Ping!");
11}
12}
13 14 int main()
15{
16 MyThread a;
17 MyThread b;
18 19 ();//自动调用run(),否则即使该线程创建,也是一开始就挂起
20 ();
21//要等待线程a,b都退出
22 ();
23 ();
24}
25 Qt线程同步
QMutex(bool recursive=FALSE)
virtual~QMutex()
void lock()//试图锁定互斥量。如果另一个线程已经锁定这个互斥量,那么这次调用将阻塞直到那个线程把它解锁。
void unlock()
bool locked()
bool tryLock()//如果另一个进程已经锁定了这个互斥量,这个函数返回假,而不是一直等到这个锁可用为止,比如,它不是阻塞的。
1//Qt 2QMutex mutex;
3 void someMethod()
4{
5 6qDebug("Hello");
7 qDebug("World");
8 ();
9}
10 11//用Java的术语,这段代码应该是:
12 void someMethod()
13{
14 synchronized{
15 qDebug("Hello");
16 qDebug("World");
17}
18}
不过在Qt中我们可用通过另一个类来简化这种应用,()()的话
就会造成死锁,别的线程永远也得不到接触该mutex锁住的共享资源的机会。尽管可以不使用lock()而使用tryLock(timeout)
来避免因为死等而造成的死锁(tryLock(负值)==lock()),但是还是很有可能造成错误。
对于上述的情况MFC中用CSingleLock或MultiLock,Boost中用boost:mutex:scoped_lock来进行解决,而在Qt中用
QMutexLocker来进行解决。下面是没有采用QMutexLocker的例子和采用QMutexLocker的方案。
plex function locks aQMutex upon entering the function and unlocks the mutex at all the exit points plexFunction(int flag)
2{
3 4
5 int retVal=0;
6 7switch(flag){
8 case 09 case 110 ();
11 return plexFunction(flag);
12 case 213{
14 int status=anotherFunction();
15 if(status 0){
16 ();
17 return-2;
18}
19 retVal=status+flag;
20}
21 break;
22 default 23 if(flag 10){
24 ();