スレッド通信のためのmyDesignは受け入れられますか？

Question

私は現在、いくつかのスレッド間の通信のための良いと働いてQt設計を作成しようとしています。私は、適用ボタンをクリックすると異なる信号を発する設定ウインドウを持っています。たとえば、SQL接続を作成するものと、他のものを変更するものがあります。私は、異なるクラスのバックグラウンドスレッドの設定を変更したい、そして、変更を加えた後、彼らは結果シグナルを出すでしょう。私の環境設定ウィンドウでは、ウィンドウを閉じるかエラーメッセージを表示する前に、すべてのシグナルが受信されるまで（真または偽の結果のいずれかで）待つ必要があります。

私は添付の画像に私のデザインを描こうとしました。それが私の目的にとって正しい方法ですか？私は現在、すべての結果を待つ方法に苦しんでいます。私はすべての結果を保存し、すべての信号が受信されているかどうか、配列をチェックするために何らかの種類の配列を作成することを考えていました。しかし、それはかなり醜いと聞こえます...すべての信号が受信されるまで待つより良い方法はありますか？

また、バックグラウンドスレッドのクラスをsingeltonとすることをお勧めしますか？私はクラスのインスタンスを1つだけ必要とするので、クラスを知る必要があるすべてのオブジェクトにポインタをドラッグする必要がないため、クラスへのアクセスが非常に簡単になります。

また、私は、データベースが接続されていて、他のスレッドから直接アクセスするかどうかを教えてくれる、MySQLクラスのパブリックメンバーを格納するのがよいかどうかを知りたいですか？

ありがとうございました！

Answer 1

QStateMachineは正確に何をしたいでしょう：それは信号を受信したときには、状態間の遷移することができます。

バックグラウンドスレッドは、クラスに基づいている必要はなく、シングルトンではないものであってもかまいません。ほとんどの場合、ファンクタをQtConcurrent::runに与えてそこに信号を発することができます。

ロジックが別々のQObjectに因数分解する必要があります。

// https://github.com/KubaO/stackoverflown/tree/master/questions/thread-jobs-39109247 
#include <QtWidgets> 
#include <QtConcurrent> 
#include <functional> 

class Controller : public QObject { 
    Q_OBJECT 
    QStateMachine m_machine{this}; 
    QState s_init{&m_machine}; 
    QState s_busy{&m_machine}; 
    QState s_idle{&m_machine}; 
    int m_activeTasks = 0; 
    void onTaskStarted() { 
     ++ m_activeTasks; 
     emit taskRunning(); 
    } 
    void onTaskDone() { 
     if (--m_activeTasks == 0) emit allTasksDone(); 
    } 
    Q_SIGNAL void taskRunning(); 
    Q_SIGNAL void allTasksDone(); 
    Q_SIGNAL void task1Done(int result); 
    Q_SIGNAL void task2Done(int result); 
public: 
    Q_SIGNAL void active(); 
    Q_SIGNAL void finished(); 
    Q_SLOT void doTask1() { 
     onTaskStarted(); 
     QtConcurrent::run([this]{ 
      QThread::sleep(2); // pretend we do some work 
      emit task1Done(42); 
     }); 
    } 
    Q_SLOT void doTask2() { 
     onTaskStarted(); 
     QtConcurrent::run([this]{ 
      QThread::sleep(5); // pretend we do some work 
      emit task2Done(44); 
     }); 
    } 
    Controller(QObject * parent = nullptr) : 
     QObject{parent} 
    { 
     // This describes the state machine 
     s_init.addTransition(this, &Controller::taskRunning, &s_busy); 
     s_idle.addTransition(this, &Controller::taskRunning, &s_busy); 
     s_busy.addTransition(this, &Controller::allTasksDone, &s_idle); 
     m_machine.setInitialState(&s_init); 
     m_machine.start(); 
     // 
     connect(this, &Controller::task1Done, this, [this](int result){ 
      onTaskDone(); 
      qDebug() << "task 1 is done with result" << result; 
     }); 
     connect(this, &Controller::task2Done, this, [this](int result){ 
      onTaskDone(); 
      qDebug() << "task 2 is done with result" << result; 
     }); 
     connect(&s_busy, &QState::entered, this, &Controller::active); 
     connect(&s_idle, &QState::entered, this, &Controller::finished); 
    } 
}; 

Q_GLOBAL_STATIC(QStringListModel, model) 
int main(int argc, char ** argv) { 
    using Q = QObject; 
    QApplication app{argc, argv}; 
    Controller ctl; 
    QWidget w; 
    QFormLayout layout{&w}; 
    QPushButton start1{"Start Task 1"}; 
    QPushButton start2{"Start Task 2"}; 
    QListView log; 
    layout.addRow(&start1); 
    layout.addRow(&start2); 
    layout.addRow(&log); 
    Q::connect(&start1, &QPushButton::clicked, &ctl, &Controller::doTask1); 
    Q::connect(&start2, &QPushButton::clicked, &ctl, &Controller::doTask2); 
    Q::connect(&ctl, &Controller::active, []{ qDebug() << "Active"; }); 
    Q::connect(&ctl, &Controller::finished, []{ qDebug() << "Finished"; }); 

    log.setModel(model); 
    qInstallMessageHandler(+[](QtMsgType, const QMessageLogContext &, const QString & msg){ 
     auto row = model->rowCount(); 
     model->insertRow(row); 
     model->setData(model->index(row), msg); 
    }); 
    w.show(); 
    return app.exec(); 
} 
#include "main.moc"