Qt 中的多线程

    这篇文章主要介绍Qt 中多线程.。多线程是一个很大的课题， 这里我介绍QThread 和QFuture的实现方式。

1. QThread

   用QThread创建线程非常简单， 只需要从QThread派生，然后重载 run成员函数即可。

class MyThread : public QThread 
{ 
    Q_OBJECT
 public: 
    MyThread(); 
    ~MyThread(); 
 protected: 
    void    run() 
    { 
        cout << "I run the thread" <<endl; 
    }
};

在主函数中我们可以这样调用：

int main(int argc, char *argv[]) 
{ 
    QCoreApplication a(argc, argv); 
    MyThread myThread; 
    myThread.start();
    return a.exec(); 
}

2. 线程同步

    Qt 提供了QMute, QReadWriteLock, QSemaphore 和QWaitCondition来同步线程。

    QMutex提供了一种保护一个变量或一段代码的方法。

     使用互斥量的一个问题就是每次只有一个线程可以访问一个变量， 如果我们要尝试多个线程访问某一个变量的话就用QReadWriteLock。

3. QFuture

    QFuture表示异步计算的结果。用QtConcurrent::run 开始一个线程，用QFutureWatcher来监视整个线程。这里写了一耳光future类：

.h

class Future : public QObject 
{ 
    Q_OBJECT 
public: 
    Future(QObject *parent = NULL); 
    ~Future();
    public slots: 
        void displayFinished() 
        { 
            cout << "finshed thread" <<endl; 
        } 
private: 
    void run_thread(); 
private: 
    QFuture<void> *future_; 
    QFutureWatcher<void> *watcher_;
};

.cpp

void my_func() 
{ 
    double sum(0.0);
    for (int i=0; i < 1000; i++) 
    { 
        for (int j = 0; j < 1000; j++) 
        { 
            sum = sum + i + j; 
        } 
    }
    cout << sum << endl;; 
}
Future::Future(QObject *parent) 
    : QObject(parent) 
{ 
    future_ = new QFuture<void>; 
    watcher_ = new QFutureWatcher<void>; 
    run_thread(); 
    cout << "now here" <<endl;
    QObject::connect(watcher_, SIGNAL(finished()), 
        this, SLOT(displayFinished())); 
}
Future::~Future() 
{
}
 void Future::run_thread() 
{ 
    *future_ = QtConcurrent::run(my_func); 
    watcher_->setFuture(*future_); 
}

当Future future的时候就会开辟一个线程来执行my_func 函数。