线程只执行一次

Question

我尝试实现这一点：当应用程序启动时，我需要创建多个线程，这些线程将使用同一个 QDialog 窗口从用户那里获取消息。当线程启动时，它会询问用户输入，如果按下 OK 按钮，它会将消息打印到控制台。我不知道为什么，但我只得到一次对话框窗口，然后它将我的一条消息打印到控制台并且应用程序完成。

我是这样描述对话框窗口的：

#include <QtWidgets>

class MyDialog : public QDialog
{
    Q_OBJECT
public:
    QWaitCondition* condition;

    explicit MyDialog(QWidget *parent = 0);

signals:
    void got_message(QString);
public slots:
    void show_message_input();
    void show_message();
private:
    QLabel* message_label;
    QVBoxLayout* vbox;
    QHBoxLayout* hbox;
    QLineEdit* message_input;
    QDialogButtonBox* dialog_buttons;

};

MyDialog::MyDialog(QWidget *parent) : QDialog(parent)
{
    setModal(true);

    message_label = new QLabel("Message");
    message_input = new QLineEdit();

    dialog_buttons = new QDialogButtonBox(QDialogButtonBox::Ok | QDialogButtonBox::Cancel);

    hbox = new QHBoxLayout();
    hbox->addWidget(message_label);
    hbox->addWidget(message_input);

    vbox = new QVBoxLayout();
    vbox->addLayout(hbox);
    vbox->addWidget(dialog_buttons);

    setLayout(vbox);

    connect(dialog_buttons, SIGNAL(accepted()), this, SLOT(accept()));
    connect(dialog_buttons, SIGNAL(rejected()), this, SLOT(reject()));

    condition = new QWaitCondition();
}

void MyDialog::show_message_input()
{
    int result = this->exec();
    if (result == QDialog::Accepted)
    {
        emit got_message(message_input->text());
        condition->wakeAll();
    }
}

这是 MyThread 类：

class MyThread : public QThread
{
    Q_OBJECT
public:
    explicit MyThread(int id, MyDialog* window, QObject *parent = 0);

signals:
    void show_input();
public slots:
    void print_message(QString);
private:
    static QMutex mutex;
    static QMutex mutex2;
    MyDialog* window;
    int id;
    void run();
    void get_captcha_value();
};

QMutex MyThread::mutex;
QMutex MyThread::mutex2;

MyThread::MyThread(int id, MyDialog* window, QObject *parent) :
    QThread(parent)
{
    this->id = id;
    this->window = window;

    connect(this, SIGNAL(show_input()), this->window, SLOT(show_message_input()));
}

void MyThread::get_captcha_value()
{
    QMutexLocker lock(&mutex);
    connect(this->window, SIGNAL(got_message(QString)), SLOT(print_message(QString)));
    emit show_input();
    mutex2.lock();
    window->condition->wait(&mutex2);
    mutex2.unlock();
}

void MyThread::run()
{
    mutex.lock();
    qDebug() << "Starting thread " << id;
    mutex.unlock();
    get_captcha_value();
    mutex.lock();
    qDebug() << "Finishing thread " << id;
    mutex.unlock();
}

void MyThread::print_message(QString message)
{
    qDebug() << message;
    QObject::disconnect(this, SLOT(print_message(QString)));
}

还有main函数：

int main(int argc, char *argv[])
{
    QApplication a(argc, argv);
    MyDialog* window = new MyDialog();
    QList<MyThread*> threads;
    for(int i = 0; i < 5; i++)
    {
        MyThread* thread = new MyThread(i, window);
        threads << thread;
        thread->start();
    }
    return a.exec();
}

Answer 1

您遇到的第一个问题是您从 QThread 继承。除非你想重写 Qt 如何处理线程，you're doing it wrong!。

您需要做的是拥有一个继承自 QObject 的类并将实例移动到新线程。继承 QThread 的主要问题是它可能会导致混淆线程亲和性（对象在哪个线程上运行）。

此外，创建比处理器内核更多的线程只是浪费资源。

我建议您read this article 了解如何使用 Qt 线程并停止从 QThread 继承。

最后，使用 QMutex 是为了保护多个线程同时访问相同的数据。您应该能够在显示的代码中删除所有这些。 Qt 中的首选方法是使用来自一个线程的数据发出信号以由另一个线程上的插槽接收。