Qtの基礎 - マルチスレッド

概要

各プログラムは起動時に1つのスレッドを持っている。
Qtでは、このスレッドのことをメインスレッドまたはGUIスレッドと呼ぶ。
Qt GUIでは、このスレッドで実行する必要がある。

全てのウィジェットやQPixmap等のいくつかのクラスは、セカンダリスレッドでは動作しない。
一般的に、セカンダリスレッドのことをワーカースレッドと呼ぶが、これはメインスレッドから処理をオフロードするために使用される。

データへの同時アクセス
2つのスレッドが同じオブジェクトへのポインタを持つ場合、
両方のスレッドが同時にそのオブジェクトにアクセスする可能性があるため、オブジェクトが破壊される可能性がある。
1つのオブジェクトに対する複数のスレッドによる同時操作を防止しなければならない。

マルチスレッドは、以下のような2つの使用例がある。

マルチコアプロセッサを利用して処理を高速化する。
長い処理をオフロードまたは他のスレッドへの呼び出しをブロックすることで、GUIスレッドやその他の時間的に重要なスレッドの応答性を維持する。

マルチスレッドの代替方法

マルチスレッドを作成する前に、考えられる代替案を検討する必要がある。
下表は、Threading Basicから引用したものである。

表. マルチスレッドの代替方法

代替案	説明
QEventLoop::processEvents()	時間が掛かる処理内において、`QEventLoop::processEvents()`を繰り返し呼び出すことで、GUIのブロッキングを防ぐことができる。ただし、ハードウェアによっては、`processEvents()`の呼び出しが頻繁に発生しすぎたり、十分な頻度で発生しないことがあるため、このソリューションはうまく拡張できない。
QSocketNotifierクラス QNetworkAccessManagerクラス QIODevice::readyRead()	1つまたは複数のスレッドを持ち、それぞれが低速なネットワーク接続上でブロッキングリードを行う代替手段である。ネットワークデータに応答する計算を素早く実行できる限り、このリアクティブ設計は、スレッドで同期的に待機するよりも優れている。リアクティブ設計は、スレッド処理よりもエラーが発生しにくく、エネルギー効率が高い。多くの場合、パフォーマンス面でもメリットがある。
QTimerクラス	バックグラウンド処理は、将来のある時点でスロットの実行をスケジュールするために、タイマを使用して便利に行うことができる。インターバルが0のタイマは、処理すべきイベントがなくなるとすぐにタイムアウトする。

Qtにおいて、推奨されるマルチスレッドの設計方法を示す。
下表は、Threading Basicから引用したものである。

表. 推奨されるマルチスレッドの設計方法

スレッドの寿命	設計方法	解決策
1度のみ	別のスレッド内でメソッドを実行して、メソッドが終了した時にスレッドを終了する。	Qtでは異なる解決策が用意されている。メソッド内において、QtConcurrent::run()を実行する。 QRunnableクラスを継承したクラスを作成して、 QThreadPool::globalInstance()->start()を実行する。 (グローバルスレッドプール内) QThreadクラスを継承したクラスを作成して、runメソッドをオーバーライドする。次に、QThread::start()を実行する。
1度のみ	長時間実行している操作は、別のスレッドに入れる必要がある。処理の途中で、GUIスレッドにステータス情報を送る必要がある。	まず、QThreadクラスを継承したクラスを作成して、runメソッドをオーバーライドする。オーバーライドしたrunメソッド内で、シグナルを送信する。次に、そのシグナルをGUIスレッドのスロットに接続する。
1度のみ	操作は、コンテナの全ての項目に対して行う。処理は、利用可能な全てのコアを使用して実行する必要がある。例: 画像のリストからサムネイルを生成する等。	QtConcurrentクラスでは、コンテナの要素ごとに操作を適用するmapメソッド、コンテナの要素を選択するfilterメソッド、残りの要素を結合するreduceメソッド等、指定するオプションが用意されている。
永久	オブジェクトを別のスレッドに常駐させて、要求に応じて異なるタスクを実行する。つまり、ワーカースレッドとの通信が必要になる。	QObjectクラスを継承したクラスを作成して、必要なスロットとシグナルを実装する。オブジェクトを実行中のイベントループを持つスレッドに移動して、シグナル / スロット接続を介してオブジェクトと通信する。
永久	オブジェクトを別のスレッドに常駐させて、ポートのポーリングや、 GUIスレッドと通信できるタスク等を繰り返し実行する。	上記と同様であるが、ワーカースレッドにてタイマを使用してポーリングを実装する。ただし、ポーリングによる解決策は止めた方がよい。 QSocketNotifierクラスを使用することもある。

スレッドの作成(非推奨) :

スレッドに低機能APIを使用しているだけでなく、後でスケーリングの問題が発生する可能性があるため、非推奨の方法である。

Qtは、高機能APIを備えたQtConcurrentを使用することを推奨する。
また、スレッド実行の結果をキャンセル、一時停止、または再開することもできます。
ただし、このレベルのAPIについても知る必要があります。

以下の例では、QThreadを継承して派生クラスを作成している。
3つのスレッドが同時に実行されて、同じコードセグメントにアクセスしている。

 // main.cpp
 
 #include <QCoreApplication>
 #include "mythread.h"
 
 int main(int argc, char *argv[])
 {
    QCoreApplication a(argc, argv);
    
    MyThread thread1("A"), thread2("B"), thread3("C");
 
    thread1.start();
    thread2.start();
    thread3.start();
 
    return a.exec();
 }

QThreadクラスのstartメソッドは、MyThreadクラスでオーバーライドするrunメソッドを呼び出すことにより、スレッドの実行を開始する。

 // mythread.h
 
 #ifndef MYTHREAD_H
 #define MYTHREAD_H
 
 #include <QThread>
 #include <QString>
 
 class MyThread : public QThread
 {
 public:
    // constructor
    // set name using initializer
    explicit MyThread(QString s);
 
    // overriding the QThread's run() method
    void run();
 private:
    QString name;
 };
 
 #endif // MYTHREAD_H

 // mythread.cpp
 
 #include "mythread.h"
 #include <QDebug>
 
 MyThread::MyThread(QString s) : name(s)
 {
 }
 
 // We overrides the QThread's run() method here
 // run() will be called when a thread starts
 // the code will be shared by all threads
 
 void MyThread::run()
 {
    for(int i = 0; i <= 100; i++)
    {
       qDebug() << this->name << " " << i;
    }
 }

Qtの基礎 - マルチスレッド

目次

概要

マルチスレッドの代替方法

スレッドの作成(非推奨) :

案内メニュー

Qtの基礎 - マルチスレッド

概要

マルチスレッドの代替方法

スレッドの作成(非推奨) :

案内メニュー

検索