用于线程通信的 myDesign 是否可以接受？

Question

我目前正在尝试为多个线程之间的通信创建一个良好且有效的Qt 设计。我有一个首选项窗口，它会在单击应用时发出不同的信号。例如，一个用于创建 SQL 连接，另一个用于更改其他内容。我想在不同类的后台线程中更改首选项，并在进行更改后发出结果信号。在我的首选项窗口中，我现在想等到收到所有信号（结果为真或假），然后再关闭窗口或打印错误消息。

我试着在附图中画出我的设计。这是我的目的的正确方法吗？我目前正在努力等待所有结果。我正在考虑创建某种数组来保存每个结果并检查数组是否接收到所有信号。但这听起来很丑陋……有没有更好的方法来等到所有信号都接收到？

将后台线程中的类设为singelton 也是一个好主意吗？我只需要一个类的实例，这样就可以很容易地访问这些类，因为我不需要将指针拖到每个需要知道类的对象上。

我也想知道，在 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"