Qt 多线程并发高阶类QtConcurrent 的使用_qtconcurrent并发

#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);                                //出现异常
    }
    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();
}

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97

QtConcurrent 是Qt中高阶的多线类模块
比 Qthread 更加方便，在使用的时候一般使用静态成员函数来实现各种形式的多线程；
典型使用方法是：处理使用list、map 这样的容器存储的数据，每一个容器里的元素会产生一个线程来处理

例子中， dataMap 插入了两个元素， 使用blockingMap函数来处理这个dataMap的数据，这种类似于信号量方式处理相同类型的批量数据，但是已经封装了类似于QMutex 这样的安全处理，保证操作的原子性；
主要区别：根据需要处理的数据量，和平台核心数自动分配线程
而且会自动动态扫描运行所在设备平台cpu 核心数线程数；