1.概要

1.要点

2.相关链接

c++ 线程交叉场景试验-CSDN博客

c++,一个线程，对外提供一个槽函数，当这个槽函数被调用的时候，线程休眠一段时间-CSDN博客

qt 我想让一个udp线程休眠一段时间，休眠后只处理最新的数据，休眠期间的缓存数据我不要了-CSDN博客 qt 一个线程让另一个线程休眠，可以吗-CSDN博客

使用 Qt 的 moveToThread 方法创建的线程，如何让线程休眠-CSDN博客 

qt 如何让一个udp线程休眠-CSDN博客 

qt 的udp线程休眠期间，通讯的缓存会怎样-CSDN博客 

如何让一个使用 Qt 的 moveToThread 方法创建的udp线程休眠，且休眠期间的缓存数据自动丢弃-CSDN博客

QUdpSocket可以主动删除缓存的数据吗-CSDN博客 

qt,一个线程，对外提供一个槽函数，当这个槽函数被调用的时候，线程休眠一段时间-CSDN博客

2.内容

在使用 Qt 的 moveToThread 方法创建的 UDP 线程中，如果你希望让线程休眠并且在休眠期间自动丢弃缓存的数据，你需要结合几个不同的技术来实现这一点。下面是一个简化的示例，展示了如何实现这个功能：

1. 创建一个 UDP 工作类：这个类处理 UDP 数据报文的接收和缓存。
2. 使用 QThread 和 moveToThread：将 UDP 工作类移动到一个新的线程中。
3. 实现休眠逻辑：通过信号和槽机制控制线程的休眠和唤醒。
4. 管理缓存数据：在休眠期间丢弃新的数据报文。

示例代码

UDPWorker.h

#ifndef UDPWORKER_H
#define UDPWORKER_H

#include <QObject>
#include <QUdpSocket>

class UDPWorker : public QObject {
    Q_OBJECT

public:
    explicit UDPWorker(QObject *parent = nullptr);
    ~UDPWorker();

public slots:
    void startListening();
    void stopListening();
    void discardData();

signals:
    void dataReceived(const QByteArray &data);

private slots:
    void readPendingDatagrams();

private:
    QUdpSocket *udpSocket;
    bool isSleeping;
};

#endif // UDPWORKER_H

UDPWorker.cpp

#include "UDPWorker.h"

UDPWorker::UDPWorker(QObject *parent)
    : QObject(parent), udpSocket(new QUdpSocket(this)), isSleeping(false) {
}

UDPWorker::~UDPWorker() {
    stopListening();
}

void UDPWorker::startListening() {
    udpSocket->bind(QHostAddress::Any, 12345);
    connect(udpSocket, &QUdpSocket::readyRead, this, &UDPWorker::readPendingDatagrams);
}

void UDPWorker::stopListening() {
    udpSocket->close();
}

void UDPWorker::discardData() {
    isSleeping = true;
}

void UDPWorker::readPendingDatagrams() {
    if (isSleeping) {
        return; // 丢弃数据
    }

    while (udpSocket->hasPendingDatagrams()) {
        QByteArray datagram;
        datagram.resize(int(udpSocket->pendingDatagramSize()));
        udpSocket->readDatagram(datagram.data(), datagram.size());

        emit dataReceived(datagram);
    }
}

MainThread.cpp

#include "UDPWorker.h"

UDPWorker::UDPWorker(QObject *parent)
    : QObject(parent), udpSocket(new QUdpSocket(this)), isSleeping(false) {
}

UDPWorker::~UDPWorker() {
    stopListening();
}

void UDPWorker::startListening() {
    udpSocket->bind(QHostAddress::Any, 12345);
    connect(udpSocket, &QUdpSocket::readyRead, this, &UDPWorker::readPendingDatagrams);
}

void UDPWorker::stopListening() {
    udpSocket->close();
}

void UDPWorker::discardData() {
    isSleeping = true;
}

void UDPWorker::readPendingDatagrams() {
    if (isSleeping) {
        return; // 丢弃数据
    }

    while (udpSocket->hasPendingDatagrams()) {
        QByteArray datagram;
        datagram.resize(int(udpSocket->pendingDatagramSize()));
        udpSocket->readDatagram(datagram.data(), datagram.size());

        emit dataReceived(datagram);
    }
}

说明

1. UDPWorker 类：
   • startListening：开始监听 UDP 报文。
   • stopListening：停止监听。
   • discardData：设置 isSleeping 标志为 true，以丢弃新接收的数据。
   • readPendingDatagrams：读取 UDP 报文，如果 isSleeping 为 true，则丢弃数据。
2. 主线程：
   • 创建 QThread 和 UDPWorker 实例。
   • 将 UDPWorker 移动到 udpThread 中。
   • 连接 udpThread 的 started 信号到 UDPWorker 的 startListening 槽。
   • 使用 QTimer::singleShot 在 5 秒后调用 discardData 方法，并让线程休眠 2 秒。

通过这种方式，你可以在需要的时候让 UDP 线程休眠，并且在休眠期间自动丢弃新接收的数据报文。

3.关联知识