한국어
Qt
 

 

Qt에서 쓰레드를 생성하는 방법은 몇가지가 있는데 여기서는 QtConcurrent를 이용한 벙법을 소개한다.

예제소스이다

 

 #include <QCoreApplication>
#include <qtconcurrentrun.h>
#include <QThread>

#ifndef QT_NO_CONCURRENT

void myRunFunction(QString name)
{
    for(int i = 0; i <= 5; i++)
    {
        qDebug() << name << " " << i <<
                    "from" << QThread::currentThread();
    }
}

int main(int argc, char *argv[])
{
    QCoreApplication a(argc, argv);

    QFuture<void> t1 = QtConcurrent::run(myRunFunction, QString("A"));
    QFuture<void> t2 = QtConcurrent::run(myRunFunction, QString("B"));
    QFuture<void> t3 = QtConcurrent::run(myRunFunction, QString("C"));

    t1.waitForFinished();
    t2.waitForFinished();
    t3.waitForFinished();

    return a.exec();
}

#else

#include <QLabel>

int main(int argc, char *argv[])
{
    QApplication app(argc, argv);
    QString text("Qt Concurrent is not yet supported on this platform");

    QLabel *label = new QLabel(text);
    label->setWordWrap(true);

    label->show();
    qDebug() << text;

    app.exec();
}
#endif

 

 

 

.pro파일에는 아래와 같은 행을 추가 해야한다.

 

 QT       += concurrent

 

예제에서 볼 수 있듯이 Worker쓰레드를 만들거나 Qthread를 생성할 필요없이 단지 할 일은 적절한 매개변수 전달과 실행될 함수를 정의하는 것이다. 예제에서 QtConcurrent의 아래와 같은 API들을 사용했다.

 

QtConcurrent::run() - 다른 쓰레드에서 함수를 실행한다.

QFuture - 비동기의 결과를 제어하는 클래스이다.

QFuture는 실제로 waitForFinished()<결과를 기다리거나>, result()<결과 값을 확인하거나>, cancel(), pause(), or resume()등의 메소드들을 제공한다.

주의할 점은 QtConcurrent::run()으로 얻은 future객체는 cancel, pause and resum을 지원하지않는다.

 

그러면 MapReduce는 무엇인가.

MapReduce는 대용량 데이터의 병렬처리 알고리즘을 단순화하기 위해 구글에서 고안했다. 

병렬 분산 알고리즘을 사용하여 빅 데이터 세트를 처리하고 생성하기위한 프로그래밍 모델 및 관련 구현인것이다.

 

QtConcurrent 프레임웍은 이러한 병렬처리를 위한 방법으로 mappedReduced를 제공한다.

API는 다음과 같다.

QFuture<T> mappedReduced(list, mapFunction, reducefunction);

 

기본 개념은 알고리즘을 두 부분으로 나누는 것인데,

하나는 입력 데이터의 개별 부분에서 병렬로 실행할 수있는 부분(map)과 또 하나는 결과를 수집하고 최종 결과를 생성하는 하나의 순차적 파트(reduce)가 그것이다.

 

아래는 Qt기본 예제인데 map-reduce 알고리즘을 사용하는 방법을 보여준다.

 

먼저 파일 목록이 입력될 목록으로 사용된다.

QStringList files = findFiles("../../", QStringList() << "*.cpp" << "*.h");

 

그런다음 기본 싱글 쓰레드로 파일 목록의 단어수를 카운팅한다.

typedef QMap<QString, int> WordCount;

WordCount singleThreadedWordCount(const QStringList &files)
{
    WordCount wordCount;
    for (const QString &file : files) {
        QFile f(file);
        f.open(QIODevice::ReadOnly);
        QTextStream textStream(&f);
        while (!textStream.atEnd()) {
            const auto words =  textStream.readLine().split(' ');
            for (const QString &word : words)
                wordCount[word] += 1;
        }
    }
    return wordCount;
}

int singleThreadTime = 0;
{
    QTime time;
    time.start();
    WordCount total = singleThreadedWordCount(files);
    singleThreadTime = time.elapsed();
    qDebug() << "single thread" << singleThreadTime;
}

 

그리고 mappedReduced API를 사용하여 역시 파일목록의 단어수를 카운팅한다.

WordCount countWords(const QString &file)
{
    QFile f(file);
    f.open(QIODevice::ReadOnly);
    QTextStream textStream(&f);
    WordCount wordCount;

    while (!textStream.atEnd()) {
        const auto words =  textStream.readLine().split(' ');
        for (const QString &word : words)
            wordCount[word] += 1;
    }

    return wordCount;
}

void reduce(WordCount &result, const WordCount &w)
{
    QMapIterator<QString, int> i(w);
    while (i.hasNext()) {
        i.next();
        result[i.key()] += i.value();
    }
}

int mapReduceTime = 0;
{
    QTime time;
    time.start();
    WordCount total = mappedReduced(files, countWords, reduce);
    mapReduceTime = time.elapsed();
    qDebug() << "MapReduce" << mapReduceTime;
}

 

위의 예제를 컴파일해서 실행해본 결과이다.

이미지 1.png

 

싱글 쓰레드 카운팅연산에 비해 map-reduce 알고리즘에 의해 처리된 시간이 2배가 넘게 빠른 결과를 보여준다.

 

QtConcurrent 및 MapReduce의 좀더 자세한 내용은 해당사이트를 참고하기 바란다.

http://doc.qt.io/qt-5/qtconcurrent-index.html

 

이 글과 연관된 다른 글
  1. [2019/05/25] QML에서 멀티 스레드(multithreading) 프로그래밍 by makersweb (885)
  2. [2014/05/24] 쓰레드 동기화 기법 by pjk (4324)
  3. [2016/10/27] 멀티 스레드환경, 스레드에 안전한 이벤트처리 by makersweb (3255)
번호 제목 글쓴이 날짜 조회 수
공지 Qt프로그래밍(QtQuick) Beginner를 위한 글 읽는 순서 운영자 2019.01.05 11879
18 Qt 어플리에이션 전역에 폰트 설정 makersweb 2018.01.24 2005
17 Qt 3D Studio 시작하기 file makersweb 2018.01.11 1655
16 QPA 플러그인과 HTML5 Backend file makersweb 2017.12.27 462
15 임의의 메모리 영역(QImage)에 QPainter를 이용하여 그리기 file makersweb 2017.12.19 1125
14 QML에서 undefined를 확인하는 방법 makersweb 2017.11.29 660
13 QPA 플러그인과 EGLFS file makersweb 2017.11.21 1669
12 타임스탬프( timestamp) 유닉스 시간 makersweb 2017.10.19 736
11 Qt Logging Rule, Qt 프레임워크 로그 출력 makersweb 2017.01.13 2249
10 QString 문자열에서 숫자만 추출해서 QString으로 반환 makersweb 2017.01.10 2112
9 멀티 스레드환경, 스레드에 안전한 이벤트처리 makersweb 2016.10.27 3255
8 Ubuntu Linux에서 Qt Creator 설치 file makersweb 2016.03.06 7738
» QtConcurrent를 이용하여 쓰레드를 만드는 방법과 MapReduce file makersweb 2016.01.24 6486
6 Qt 프로그래밍의 시작 makersweb 2015.10.25 8538
5 Qt의 스레드간 시그널 슬롯의 커넥션타입 makersweb 2015.10.24 5471
4 Qt의 시그널 슬롯 시스템 file makersweb 2015.10.20 10180
3 Qt Image Provider를 이용한 Qml애플리케이션으로 이미지 제공 makersweb 2015.10.18 4610
2 Qml 사용자 ScrollBar 구현 file makersweb 2015.07.24 4991
1 z-order 를 컨트롤 하기위한 방법 makersweb 2015.05.13 5292