学步园

一个进程可以分成多个线程，每个线程有自己的Register Set(寄存器组)和Stack，但共享进程的Heap、Data、Code （见下图）

创建线程：

       在Qt中要创建线程，第一步是继承QThread类，第二步是实现其中的run()函数，该方法为protected型，由start()函数来调用。下面是例子：

//Producer.h<br /> #ifndef PRODUCER_H<br /> #define PRODUCER_H<br /> #include <QThread><br /> #include <QString><br /> class Producer : public QThread<br /> {<br /> public:<br /> Producer(const QString &prefix);<br /> void stopThread(bool isStop);<br /> protected:<br /> void produceMessage(int x);<br /> void run();<br /> private:<br /> QString m_prefix ;<br /> bool stopThreads ;<br /> };<br /> #endif // PRODUCER_H<br /> //Producer.cpp<br /> #include <QDebug><br /> #include "Producer.h"<br /> Producer::Producer(const QString &prefix) : QThread()<br /> {<br /> m_prefix = prefix;<br /> stopThreads = false;<br /> }<br /> void Producer::stopThread(bool isStop) {<br /> stopThreads = isStop;<br /> }<br /> void Producer::produceMessage(int x)<br /> {<br /> qDebug() << QString("Producing %1: %2").arg(m_prefix).arg(x);<br /> }<br /> void Producer::run() {<br /> for(int i = 0; !stopThreads; i++) {<br /> produceMessage(i);<br /> msleep(rand()000+1);<br /> }<br /> }<br /> //main.cpp<br /> #include <QApplication><br /> #include <QMessageBox><br /> #include <QDebug><br /> #include "Producer.h"<br /> bool stopThreads = false;<br /> int main(int argc, char *argv[])<br /> {<br /> QApplication a(argc, argv);<br /> Producer pa("A"); //创建线程对象<br /> Producer pb("B");<br /> pa.start(); // 启动线程<br /> pb.start();<br /> QMessageBox::information( 0, "Threading", "Close me to stop!" );<br /> pa.stopThread(true);<br /> pb.stopThread(true);<br /> pa.wait(); //等待线程结束<br /> pb.wait();<br /> return 0;<br /> }<br />

线程同步：

        多个线程在运行的时候，可以看作是并行的。当线程之间有共享数据时，为了使得数据状态能够保持连贯性而不被破坏，需要使用线程同步来保护某数据或者某段代码（即把某数据的存取或者某段代码的执行由并行变成串行，从而达到保护的目的）。而线程中对数据或代码的保持一般使用“锁”（在QT中叫mutex）来把它们“锁”住，使得在每个时刻这个数据/代码只能被一个线程访问。QT中的mutex使用有下面几种：

• QMutex
• QMutexLocker
• QReadWriteLock
• QReadLocker / QWriteLocker
• QSemaphore

//QMutex: 保护lock()与unlock()之间的代码<br /> QMutex mutex;<br /> mutex.lock();<br /> //需要保护的代码或数据存取<br /> mutex.unlock();<br /> //QLocker: 保护从QLocker对象创建后的整个函数体内的代码，函数结束后该locker会自动释放“锁”<br /> void fun() {<br /> QMutexLocker locker(&mutex);<br /> //some other code<br /> }<br /> //QReadWriteLock与QMutex比较相似，不过它提供的函数是：lockForRead()、lockForWrite()<br /> //同样，QReadLocker、QWriteLocker与QLocker的使用相似，能够自动释放“锁”<br /> //QSemaphore: 上面几种“锁”只能保护一个数据，如果有多个数据要保护，则需要使用QSemaphore<br /> QSemaphore s( 10 );<br /> s.acquire(); // s.available() = 9<br /> s.acquire(5); // s.available() = 4<br /> s.release(2); // s.available() = 6<br /> s.release(); // s.available() = 7<br /> s.release(5); // s.available() = 12<br /> s.tryAcquire(15); // s.available() = 12<br />

从上面可以看出：以“Locker”结尾的“锁”用起来更加方便，因为它的对象在销毁时会自动释放锁；而不带"Locker"锁在使用时要注意处理如异常、条件判断等以保证锁能够被释放，否则可能会造成线程“锁”不释放，而被“锁”住的资源/代码不能够被别的线程访问。