Semaphore怎么使用

本篇内容介绍了“Semaphore怎么使用”的有关知识,在实际案例的操作过程中,不少人都会遇到这样的困境,接下来就让小编带领大家学习一下如何处理这些情况吧!希望大家仔细阅读,能够学有所成!

昆玉ssl适用于网站、小程序/APP、API接口等需要进行数据传输应用场景,ssl证书未来市场广阔!成为成都创新互联的ssl证书销售渠道,可以享受市场价格4-6折优惠!如果有意向欢迎电话联系或者加微信:18982081108(备注:SSL证书合作)期待与您的合作!

每一个成熟的开发工具,都会附带很多示例,用来说明工具本身和相关语言的用法。编程者往往会忽略这些例子而直奔自己的开发目标。基本上这也不是什么大问题,因为那些例子大多很简单,用的时候看一下就行了。但是Qt中关于Semaphore的实例,却是无论如何都不应该忽略的。

代码说明

全局变量

//数据量
const int DataSize = 100000;
//缓冲区大小
const int BufferSize = 8192;  
//缓冲区
char buffer[BufferSize];      
//缓冲区空闲空间Semaphore
QSemaphore freeBytes(BufferSize);  
//缓冲区数据Semaphore
QSemaphore usedBytes;         

写数据线程

class Producer : public QThread
{
public:
 void run() override
 {
      for (int i = 0; i < DataSize; ++i) {
         freeBytes.acquire();
         buffer[i % BufferSize]
               = "ACGT"[(int)qrand() % 4];
         usedBytes.release();
     }
 }
};

首先略过两个Semaphore来读程序。run方法向缓冲区中写入数据。由于buffer的下标为i % BufferSize,所以这是一个循环队列。

接下来看两个Semaphore的用法。freeBytes是空闲领域关联的Semaphore,只要循环队列中有空闲空间,acquire就会顺利通过,否则写数据线程在acquire方法处发生阻塞。当数据写入成功以后,调用usedBytes的release方法,增加usedBytes的计数值。

读数据线程

class Consumer : public QThread
{
public:
 void run() override
 {
     for (int i = 0; i < DataSize; ++i) {
         usedBytes.acquire();
         fprintf(stderr, "%c",    
                  buffer[i % BufferSize]);
         freeBytes.release();
     }
 }
};

run方法从循环队列中读数据。关键还是两个Semaphore的用法。usedBytes是数据领域关联的Semaphore,只用循环队列中有数据,acquire就会顺利通过,否则读数据线程在acquire方法处发生阻塞。当数据读出成功以后,调用freeBytes的release方法,增加freeBytes的计数值。

主程序

int main(int argc, char *argv[])
{
 Producer producer;
 Consumer consumer;
 producer.start();
 consumer.start();
 producer.wait();
 consumer.wait();
 return 0;
}

主程序很简单,分别启动两个线程,然后就安静地等待两个线程结束。

“Semaphore怎么使用”的内容就介绍到这里了,感谢大家的阅读。如果想了解更多行业相关的知识可以关注创新互联网站,小编将为大家输出更多高质量的实用文章!


分享标题:Semaphore怎么使用
网页地址:http://pwwzsj.com/article/ipijgo.html