QQueue是线程安全的？-QT开发中文网

在Qt中，QQueue不是线程安全的。因此，在多线程环境下使用QQueue时，需要考虑数据竞争和未定义行为问题。

如果需要在多个线程之间共享队列对象，并且确保线程安全性，可以使用Qt提供的线程安全类，如QMutex、QReadWriteLock等来保护访问。

另外，Qt还提供了一些跨线程通信的机制，例如QtConcurrent::BlockingQueuedConnection和Qt::QueuedConnection等方式来实现多个线程之间的通信和数据传输。

示例代码：

#include <QDebug>
#include <QMutex>
#include <QThread>
#include <QWaitCondition>

class MyWorker : public QObject
{
    Q_OBJECT
public:
    explicit MyWorker(QQueue<int>& queue, QMutex& mutex, QWaitCondition& waitCond, QObject *parent = nullptr) :
        QObject(parent), m_queue(queue), m_mutex(mutex), m_waitCond(waitCond) {}

public slots:
    void doWork() {
        // 从队列头部取出元素并打印
        m_mutex.lock();
        while (m_queue.isEmpty()) {
            m_waitCond.wait(&m_mutex);
        }
        int value = m_queue.dequeue();
        qDebug() << "Removed:" << value;
        m_mutex.unlock();
    }

private:
    QQueue<int>& m_queue;
    QMutex& m_mutex;
    QWaitCondition& m_waitCond;
};

int main()
{
    QQueue<int> queue{1, 2, 3};
    QMutex mutex;
    QWaitCondition waitCond;

    // 创建多个线程，每个线程从队列中取出一个元素并打印
    QList<QThread*> threads;
    for (int i = 0; i < 3; ++i) {
        MyWorker* worker = new MyWorker(queue, mutex, waitCond);
        QThread* thread = new QThread();
        worker->moveToThread(thread);
        QObject::connect(thread, &QThread::started, worker, &MyWorker::doWork);
        threads.append(thread);
    }

    // 启动所有线程，并唤醒等待条件
    for (auto thread : threads) {
        thread->start();
    }
    waitCond.wakeAll();

    // 等待所有线程结束
    for (auto thread : threads) {
        thread->wait();
        delete thread;
    }

    return 0;
}

输出结果：