当前位置： 移动技术网 > IT编程>开发语言>C/C++ > 【Qt学习】09 Qt多线程之QWaitCondition

【Qt学习】09 Qt多线程之QWaitCondition

2020年07月27日  | 移动技术网IT编程  | 我要评论

概述

学习内容：多线程QWaitCondition的使用。

 

环境

IDE：Qt creator 4.11.0

编译器：MinGW 5.3.0 32bit for C++

 

例子

功能：验证QWaitCondition类中wakeOne与wait函数的用法。

下列代码仅供参考。

1、mythreada.h

#ifndef MYTHREADA_H
#define MYTHREADA_H

#include <QThread>
#include <QWaitCondition>
#include <QMutex>
#include <QDebug>
#include <mythreadb.h>

class MyThreadA : public QThread
{
    Q_OBJECT

public:
    MyThreadA();

public:
    void run();
    void wakeFunc();

private:
    QWaitCondition m_wait;
    QMutex m_mutex;
    MyThreadB m_ThreadB;
    QString m_qstrLog;

};

#endif // MYTHREADA_H

 

2、mythreada.cpp

#include "mythreada.h"

MyThreadA::MyThreadA()
{

}

void MyThreadA::run()
{
    static int x = 0;

    qDebug() << "Thread A run()";

    while (true)
    {
        qDebug() << "------> 1 <------";
        m_mutex.lock();

        x ++;
        if (x > 3)
        {
            m_ThreadB.start();
        }

        m_qstrLog = QString("x = %1").arg(x);
        qDebug() << m_qstrLog;

        m_wait.wait(&m_mutex);
        m_mutex.unlock();

        qDebug() << "------> 2 <------";
    }

}

void MyThreadA::wakeFunc()
{
    if (!isRunning())
    {
        start();
    }
    else
    {
        m_wait.wakeOne();
    }
}

 

3、mythreadb.h

#ifndef MYTHREADB_H
#define MYTHREADB_H

#include <QThread>
#include <QDebug>

class MyThreadB : public QThread
{
    Q_OBJECT
public:
    MyThreadB();

public:
    void run();
};

#endif // MYTHREADB_H

 

4、mythreadb.cpp

#include "mythreadb.h"

MyThreadB::MyThreadB()
{

}

void MyThreadB::run()
{
    qDebug() << "Thread B ia active.";
}

 

5、mainwindow.cpp

#include "mainwindow.h"
#include "ui_mainwindow.h"

MainWindow::MainWindow(QWidget *parent)
    : QMainWindow(parent)
    , ui(new Ui::MainWindow)
{
    ui->setupUi(this);

    m_pThreadA = new MyThreadA();
}

MainWindow::~MainWindow()
{
    delete ui;
}

void MainWindow::on_pushButton_clicked()
{
    qDebug() << "Button clicked.";
    m_pThreadA->wakeFunc();
}

 

总结

1、运行效果如下图所示。

 

2、调试信息

Button clicked.
Thread A run()
------> 1 <------
"x = 1"
Button clicked.
------> 2 <------
------> 1 <------
"x = 2"
Button clicked.
------> 2 <------
------> 1 <------
"x = 3"
Button clicked.
------> 2 <------
------> 1 <------
"x = 4"
Thread B ia active.

3、知识点

m_wait.wait(&m_mutex);

相当于 

m_mutex.unlock();
m_wait.wait(); //线程处于阻塞状态等待信号 注意(unlock和wait是原子的)
m_mutex.lock();

4、代码下载

地址：

本文地址：https://blog.csdn.net/sunriver2000/article/details/107596577

您可能感兴趣的文章:

如对本文有疑问， 点击进行留言回复！！

相关文章:

验证码：
最近更新的文章
大家感兴趣的文章
移动技术网