您的位置:首页 > 编程语言 > Qt开发

QSemaphore 信号量

2017-04-10 11:03 197 查看
QSemaphore类提供了一种通用的计数信号量。信号量是互斥锁的泛化。一个互斥锁只能被锁住一次,而一个信号量可以被多次请求。所以,信号量通常用来保护某个特定数量的资源。

信号量支持两种基本的操作,acquire()和release():

acquire(n)尝试请求n个资源。如果目前没有这么多资源可用,该次调用会阻塞。
release(n)释放n个资源。
同样,类似于QMutex,改类也有tryAcquire()函数,该函数会在不能请求到资源时立即返回;我们还可以使用available()函数在任何时候得到可用资源的个数。
下面,我们使用一个值为1的信号量来模拟互斥锁,同步两个线程。
新建一个Qt控制台程序,再建两个线程类Thread1和Thread2,继承QThread类。代码如下:
#ifndef THREAD1_H
#define THREAD1_H
#include <QThread>
#include <QSemaphore>

extern QSemaphore sem;
class Thread1 : public QThread
{
public:
Thread1(QObject *parent = Q_NULLPTR);

protected:
void run() Q_DECL_OVERRIDE;
};

#endif // THREAD1_H
#include "thread1.h"
#include <QDebug>

Thread1::Thread1(QObject *parent)
:QThread(parent)
{

}

void Thread1::run()
{
while(1)
{
sem.acquire();
qDebug() << "thread1: " << currentThreadId();
sem.release();
msleep(500);
}
}


Thread2的实现类似,我们只是循环的打印出每个线程的id。但由于我们使用二值信号量进行同步,所以两个线程会交替输出。运行结果如下:

内容来自用户分享和网络整理,不保证内容的准确性,如有侵权内容,可联系管理员处理 点击这里给我发消息