Qt 之 QtConcurrent

  本文以 Qt 中的 QtConcurrent::run() 函數為例，介紹如何將函數運行在單獨的線程中。

1  QtConcurrent::run()

  QtConcurrent 是命名空間 (namespace)，它提供了高層次的函數接口 (APIs)，使所寫程序，可根據計算機的 CPU 核數，自動調整運行的線程數目。

  下面是 Qt 例程 runfunction，對應目錄為  D:\Qt\Qt5.12.3\Examples\Qt-5.12.3\qtconcurrent\runfucntion

1.1  .pro 工程文件

  使用 QtConcurrent 模塊，需要在 .pro 中添加： QT += concurrent

QT += concurrent widgets
CONFIG += console

SOURCES += main.cpp

1.2  main.cpp

#include <QString>
#include <QDebug>
#include <QThread>
#include <QApplication>

#include "qtconcurrentrun.h"

using namespace QtConcurrent;

void func(QString name)
{
    qDebug() << name << "from" << QThread::currentThread();
}

int main(int argc, char **argv)
{
    QApplication app(argc, argv);

    QFuture<void> fut1 = run(func, QString("Thread 1"));
    QFuture<void> fut2 = run(func, QString("Thread 2"));

    fut1.waitForFinished();
    fut2.waitForFinished();
}

  用 QtConcurrent::run() 函數，分別將  func() 運行在兩個不同的線程中，輸出結果如下：

 

"Thread 1" from QThread(0x1b74fd2ebc0, name = "Thread (pooled)")
"Thread 2" from QThread(0x1b74fd534e0, name = "Thread (pooled)")

 

  下面是 QtConcurrent::run() 的詳細使用，閱讀完 2 和 3，再看上面的 runfunction 例程，就容易理解了。

 2  普通函數

2.1  將函數運行在某一個線程中

extern void func();
QFuture<void> future = QtConcurrent::run(func);

  如果要為其指定線程池，可以將線程池的指針作為第一個參數傳遞進去

extern void func();
QThreadPool pool;
QFuture<void> future = QtConcurrent::run(&pool, func);

2.2  向該函數傳遞參數

  需要傳遞的參數，則跟在函數名之后，依次加入

extern void FuncWithArguments(int arg1, const QString &string);

 int integer = ...;
 QString string = ...;

 QFuture<void> future = QtConcurrent::run(FuncWithArguments,integer,string);

2.3  獲取該函數的計算結果

extern QString Func(const QByteArray &input);

QByteArray byte_array = ...;

QFuture<QString> future = QtConcurrent::run(func, byte_array);
...
QString result = future.result();

 

3  成員函數

  將類中的成員函數運行在某一個線程中，可將指向該類實例的 引用或指針 作為 QtConcurrent::run 的第一個參數傳遞進去，

  常量成員函數一般傳遞 常量引用 (const reference)，而非常量成員函數一般傳遞 指針 (pointer)

3.1  常量成員函數

   在一個單獨的線程中，調用 QByteArray 的常量成員函數 split()，傳遞給 run() 函數的參數是 bytearray

  QByteArray bytearray = "hello world";
  QFuture<QList<QByteArray> > future = QtConcurrent::run(bytearray, &QByteArray::split, ',');
  ...
  QList<QByteArray> result = future.result();

3.2  非常量成員函數

   在一個單獨的線程中，調用 QImage 的非常量成員函數 invertPixels()，傳遞給 run() 函數的參數是 &image

  QImage image = ...;
  QFuture<void> future = QtConcurrent::run(&image, &QImage::invertPixels, QImage::InvertRgba);
  ...
  future.waitForFinished();
  // At this point, the pixels in 'image' have been inverted

 

參考資料：

  Qt Assistant | Qt 5.12 | Qt Concurrent | Concurrent Run