Qt跨線程的信號和槽的使用

https://blog.csdn.net/libaineu2004/article/details/86487354

connect用於連接qt的信號和槽，在qt編程過程中不可或缺。它其實有第五個參數，只是一般使用默認值，在滿足某些特殊需求的時候可能需要手動設置。

Qt::AutoConnection： 默認值，使用這個值則連接類型會在信號發送時決定。如果接收者和發送者在同一個線程，則自動使用Qt::DirectConnection類型。如果接收者和發送者不在一個線程，則自動使用Qt::QueuedConnection類型。

Qt::DirectConnection：槽函數會在信號發送的時候直接被調用，槽函數運行於信號發送者所在線程。效果看上去就像是直接在信號發送位置調用了槽函數。這個在多線程環境下比較危險，可能會造成奔潰。

Qt::QueuedConnection：槽函數在控制回到接收者所在線程的事件循環時被調用，槽函數運行於信號接收者所在線程。發送信號之后，槽函數不會立刻被調用，等到接收者的當前函數執行完，進入事件循環之后，槽函數才會被調用。多線程環境下一般用這個。

Qt::BlockingQueuedConnection：槽函數的調用時機與Qt::QueuedConnection一致，不過發送完信號后發送者所在線程會阻塞，直到槽函數運行完。接收者和發送者絕對不能在一個線程，否則程序會死鎖。在多線程間需要同步的場合可能需要這個。

Qt::UniqueConnection：這個flag可以通過按位或（|）與以上四個結合在一起使用。當這個flag設置時，當某個信號和槽已經連接時，再進行重復的連接就會失敗。也就是避免了重復連接。
 

QObject::connect()本身是線程安全的。槽函數一般是不安全的。

1.信號和槽函數在同一個線程中的情況
class Test: public QMainWindow
{
    Q_OBJECT
Test()
signals:
    void sigFirst();
private slots:
    void slotFirst();
}

Test::Test(QWidget *parent)
: QMainWindow(parent) {
    ui.setupUi(this);
    for (int i = 0; i < 5; i++) {//采用默認方式，連接5次
        connect(this, SIGNAL(sigFirst()), this, SLOT(slotFirst()));
    }

    emit sigFirst();
}


void Test::slotFirst() {
    numCoon++;
    qDebug() << QStringLiteral("信號第")<<numCoon<<QStringLiteral("次連接");
}

運行之后的輸出內容：

"信號第" 1 "次連接"
"信號第" 2 "次連接"
"信號第" 3 "次連接"
"信號第" 4 "次連接"
"信號第" 5 "次連接"`

如果代碼修改一下，改為：

connect(this, SIGNAL(sigFirst()), this, SLOT(slotFirst()), Qt::UniqueConnection);//注意第五個參數

再次運行一下，查看輸出：

"信號第" 1 "次連接"

這次只發送了一次信號，但是咱們連接了5次，所以采用Qt::UniqueConnection方式連接，無論連接多少次，只發送一次信號，也只會執行一次槽函數

2.信號和槽函數在不同線程中的情況
自定義線程類：

#pragma once

#include <QThread>

class QtTestThread : public QThread {
    Q_OBJECT

public:
    QtTestThread(QObject *parent);
    ~QtTestThread();
protected:
    void run();
signals:
    void sigSecond();
};

#include "QtTestThread.h"
#include <QDebug>

QtTestThread::QtTestThread(QObject *parent)
: QThread(parent) {
}

QtTestThread::~QtTestThread() {
}

void QtTestThread::run() {
    emit sigSecond();
    qDebug() << QStringLiteral("信號發送完畢！");
}

調用線程類：

class QtTestThread;
class Test: public QMainWindow
{
    Q_OBJECT
Test()
signals:
    void sigFirst();
private slots:
    void slotThread();
private:
    QtTestThread* testThread;
}

#include "QtTestThread.h"
Test::Test(QWidget *parent)
: QMainWindow(parent) {
    ui.setupUi(this);

    testThread = new QtTestThread(this);
    connect(testThread, SIGNAL(sigSecond()), this, SLOT(slotThread()));//沒有第五個參數，也就是采用默認的連接方式

    testThread->start();
}

void Test::slotThread() {
    qDebug() << QStringLiteral("線程發送的信號-槽函數執行！");
    QThread::sleep(3);
}

運行一下，輸出內容：

"信號發送完畢！"
"線程發送的信號-槽函數執行！"

由此可以看出，信號發送完成信號后，就直接運行下面的代碼了，而發送的信號就會被放到主線程的信號隊列中等待執行。

咱們信號槽的連接方式修改一下，添加信號槽的連接方式 Qt::BlockingQueuedConnection：

connect(testThread, SIGNAL(sigSecond()), this, SLOT(slotThread()), Qt::BlockingQueuedConnection);

再次運行一下：

"線程發送的信號-槽函數執行！"
"信號發送完畢！"//時間等待3秒之后才輸出這句話

采用Qt::BlockingQueuedConnection的連接方式就實現了信號和槽函數的同步執行。

 

--

完整的源碼如下：

頭文件：

#ifndef MAINWINDOW_H
#define MAINWINDOW_H
 
#include <QMainWindow>
#include <QThread>
 
namespace Ui {
class MainWindow;
}
 
class QtTestThread : public QThread {
    Q_OBJECT
 
public:
    QtTestThread(QObject *parent);
    ~QtTestThread();
 
protected:
    void run();
 
signals:
    void sigSecond();
};
 
class MainWindow : public QMainWindow
{
    Q_OBJECT
 
public:
    explicit MainWindow(QWidget *parent = nullptr);
    ~MainWindow();
 
private:
    Ui::MainWindow *ui;
 
signals:
    void sigFirst();
 
private slots:
    void slotFirst();
    void slotThread();
 
private:
    QtTestThread* testThread;
    int numCoon;
};
 
#endif // MAINWINDOW_H

源文件：

#include "mainwindow.h"
#include "ui_mainwindow.h"
#include <QDebug>
 
QtTestThread::QtTestThread(QObject *parent)
    : QThread(parent)
{
}
 
QtTestThread::~QtTestThread()
{
}
 
void QtTestThread::run()
{
    emit sigSecond();
    qDebug() << QStringLiteral("信號發送完畢！");
}
 
MainWindow::MainWindow(QWidget *parent) :
    QMainWindow(parent),
    ui(new Ui::MainWindow)
{
    ui->setupUi(this);
 
    for (int i = 0; i < 5; i++) {//采用默認方式，連接5次
        //connect(this, SIGNAL(sigFirst()), this, SLOT(slotFirst()));//沒有第五個參數，也就是采用默認的連接方式
        connect(this, SIGNAL(sigFirst()), this, SLOT(slotFirst()), Qt::UniqueConnection);//注意第五個參數
    }
 
    numCoon = 0;
    //emit sigFirst();
 
    testThread = new QtTestThread(this);
    //connect(testThread, SIGNAL(sigSecond()), this, SLOT(slotThread()));//沒有第五個參數，也就是采用默認的連接方式
    //connect(testThread, SIGNAL(sigSecond()), this, SLOT(slotThread()), Qt::QueuedConnection);//效果同上
    connect(testThread, SIGNAL(sigSecond()), this, SLOT(slotThread()), Qt::BlockingQueuedConnection);//效果不同
    testThread->start();
}
 
MainWindow::~MainWindow()
{
    delete ui;
}
 
void MainWindow::slotFirst()
{
    numCoon++;
    qDebug() << QStringLiteral("信號第")<<numCoon<<QStringLiteral("次連接");
}
 
void MainWindow::slotThread()
{
    qDebug() << QStringLiteral("線程發送的信號-槽函數執行！");
    QThread::sleep(3);
}