QSemaphore 信号量
2017-04-10 11:03
197 查看
QSemaphore类提供了一种通用的计数信号量。信号量是互斥锁的泛化。一个互斥锁只能被锁住一次,而一个信号量可以被多次请求。所以,信号量通常用来保护某个特定数量的资源。
信号量支持两种基本的操作,acquire()和release():
acquire(n)尝试请求n个资源。如果目前没有这么多资源可用,该次调用会阻塞。
release(n)释放n个资源。
同样,类似于QMutex,改类也有tryAcquire()函数,该函数会在不能请求到资源时立即返回;我们还可以使用available()函数在任何时候得到可用资源的个数。
下面,我们使用一个值为1的信号量来模拟互斥锁,同步两个线程。
新建一个Qt控制台程序,再建两个线程类Thread1和Thread2,继承QThread类。代码如下:
Thread2的实现类似,我们只是循环的打印出每个线程的id。但由于我们使用二值信号量进行同步,所以两个线程会交替输出。运行结果如下:
信号量支持两种基本的操作,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。但由于我们使用二值信号量进行同步,所以两个线程会交替输出。运行结果如下:
相关文章推荐
- QT 信号量QSemaphore的使用
- Qt的QWaitCondition、信号量QSemaphore
- QT之使用QSemaphore信号量同步线程小例子
- Qt信号量QSemaphore
- Qt信号量QSemaphore
- 【Qt多线程之信号量】Qsemaphore
- QT——QSemaphore(信号量)
- Qt信号量QSemaphore
- Linux编程常用的函数(四) 信号量
- Qt中QThread 互斥,事件,临界区,信号量
- 共享内存(shared memory)和信号量(semaphore)简介(转)
- 信号量(Semaphore)
- 获取信号量
- <linux线程>POSIX无名信号量的基本操作---两个线程间的通信
- 自旋锁与信号量
- linux 自旋锁和信号量【转】
- Linux 2.4 内核的同步机制(1) (信号量)
- 进程间通信-信号量
- 使用信号量的生产者-消费者问题
- 进程间通信(3)-信号量的使用