QSmaphore类型如何使用-QT开发中文网

QSemaphore 是 Qt 框架中用于实现信号量的类，主要用于控制对共享资源的访问。以下是 QSemaphore 的基本用法：

1. 包含头文件

在你的源文件中包含 QSemaphore 的头文件：

#include <QSemaphore>

2. 创建 QSemaphore 实例

你可以通过构造函数来创建一个信号量。例如，下面的代码创建了一个初始值为 3 的信号量：

QSemaphore semaphore(3);

3. 使用 acquire() 和 release()

acquire(int n = 1): 请求信号量。如果当前可用的信号量数量小于请求数量，则该调用会阻塞，直到有足够的信号量可用。
release(int n = 1): 释放指定数量的信号量，将其添加到可用信号量计数中。

示例代码

下面是一个简单的示例，展示了如何使用 QSemaphore 在多线程环境中限制对共享资源的访问：

#include <QCoreApplication>
#include <QThread>
#include <QSemaphore>
#include <iostream>

class Worker : public QThread {
public:
    Worker(QSemaphore* semaphore) : m_semaphore(semaphore) {}

    void run() override {
        // 请求信号量
        m_semaphore->acquire();
        std::cout << "Thread " << QThread::currentThreadId() << " is working." << std::endl;
        
        // 模拟工作负载
        QThread::sleep(2); 

        // 释放信号量
        m_semaphore->release();
        std::cout << "Thread " << QThread::currentThreadId() << " has finished work." << std::endl;
    }

private:
    QSemaphore* m_semaphore;
};

int main(int argc, char *argv[]) {
    QCoreApplication a(argc, argv);

    QSemaphore semaphore(2); // 限制最多只有两个线程同时执行

    const int numThreads = 5;
    Worker workers[numThreads] = { &semaphore, &semaphore, &semaphore, &semaphore, &semaphore };

    for (int i = 0; i < numThreads; ++i) {
        workers[i].start();
    }

    for (int i = 0; i < numThreads; ++i) {
        workers[i].wait();
    }

    return a.exec();
}

在这个示例中，我们创建了一个 QSemaphore 实例，该实例允许最多两个线程同时访问共享资源。五个线程尝试获取这个信号量并执行工作，然后释放它。您可以看到输出显示哪些线程正在工作以及何时完成。