#include <QCoreApplication> #include <QtConcurrent> #include <QDebug> #include <iostream> #include <csignal> #include <unistd.h> using namespace std;int g_1 = 0;// 測試中斷方式 void signalHandler(int signum) {qDebug() << "Receive signal （"<< signum << "）。"; }void function(int &num) {num = num * 10;qDebug() << QThread::currentThreadId() <<num; }double fuc(int a ,int b) {if ( b == 0 ) {throw b;}double ret = a/b;return ret; }int testTryCatch() {double res;try //定義異常{res = fuc(6, 3);cout<<"The result of x/y is : "<<res<<endl;res = fuc(4,0); //出現(xiàn)異常}catch(double) //捕獲并處理異常{cerr<<"error of dividing zero.\n";exit(1); //異常退出程序}return 0; }void mapFunc(QString& data){qDebug() << data << QThread::currentThreadId();data.append("_new");g_1 += 1;qDebug()<< g_1 << QThread::currentThreadId(); }int main(int argc, char *argv[]) {QCoreApplication a(argc, argv);// testTryCatch();// auto lmd = [] (int& para) { // para += 10; // return para; // };// int p(10); // qDebug() << lmd(p); // qDebug() << p; QList<int> list = {1,2,3,4,5}; QtConcurrent::map(list, function); // qDebug() << QThread::currentThreadId(); QtConcurrent::run(function, 1);// signal(SIGINT, signalHandler); // while (true) { // qDebug() << "to sleep"; // sleep(1); // }QMap<int, QString> dataMap;dataMap.insert(1, "first");dataMap.insert(2, "second");QtConcurrent::blockingMap(dataMap, mapFunc);qDebug() << dataMap;qDebug() << g_1;return a.exec(); }

QtConcurrent 是Qt中高階的多線類模塊
比 Qthread 更加方便，在使用的時候一般使用靜態(tài)成員函數(shù)來實現(xiàn)各種形式的多線程；
典型使用方法是：處理使用list、map 這樣的容器存儲的數(shù)據(jù)，每一個容器里的元素會產(chǎn)生一個線程來處理

例子中， dataMap 插入了兩個元素， 使用blockingMap函數(shù)來處理這個dataMap的數(shù)據(jù)，這種類似于信號量方式處理相同類型的批量數(shù)據(jù)，但是已經(jīng)封裝了類似于QMutex 這樣的安全處理，保證操作的原子性；
主要區(qū)別：根據(jù)需要處理的數(shù)據(jù)量，和平臺核心數(shù)自動分配線程
而且會自動動態(tài)掃描運行所在設(shè)備平臺cpu 核心數(shù)線程數(shù)；

總結(jié)

以上是生活随笔為你收集整理的Qt 多线程并发高阶类QtConcurrent 的使用的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯，歡迎將生活随笔推薦給好友。