信號(hào)量和Mutex類(lèi)似,表示可用資源的數(shù)量,和Mutex不同的是,這個(gè)數(shù)量可以大于1,即如果信號(hào)量描述的資源數(shù)目是1時(shí),此時(shí)的信號(hào)量和互斥鎖相同。
創(chuàng)新互聯(lián)是一家集網(wǎng)站建設(shè),洪澤企業(yè)網(wǎng)站建設(shè),洪澤品牌網(wǎng)站建設(shè),網(wǎng)站定制,洪澤網(wǎng)站建設(shè)報(bào)價(jià),網(wǎng)絡(luò)營(yíng)銷(xiāo),網(wǎng)絡(luò)優(yōu)化,洪澤網(wǎng)站推廣為一體的創(chuàng)新建站企業(yè),幫助傳統(tǒng)企業(yè)提升企業(yè)形象加強(qiáng)企業(yè)競(jìng)爭(zhēng)力??沙浞譂M(mǎn)足這一群體相比中小企業(yè)更為豐富、高端、多元的互聯(lián)網(wǎng)需求。同時(shí)我們時(shí)刻保持專(zhuān)業(yè)、時(shí)尚、前沿,時(shí)刻以成就客戶(hù)成長(zhǎng)自我,堅(jiān)持不斷學(xué)習(xí)、思考、沉淀、凈化自己,讓我們?yōu)楦嗟钠髽I(yè)打造出實(shí)用型網(wǎng)站。
下面我們看看POSIX semaphore庫(kù)函數(shù),它既可以用于同一進(jìn)程的線程間同步,也可以用于不同進(jìn)程間的同步。
1. int sem_init(sem_t *sem,int pshared,unsigned int value)
我們可以用此函數(shù)來(lái)創(chuàng)建一個(gè)未命名的信號(hào)量,pshared參數(shù)表明是否在多個(gè)進(jìn)程中使用信號(hào)量,如果是,將其設(shè)置為非0 值,value參數(shù)制定了信號(hào)量的初始值。
2.int sem_destroy(sem_t *sem)
當(dāng)我們對(duì)未命名的信號(hào)量使用已完成時(shí),可以調(diào)用sem_destroy函數(shù)丟棄它。調(diào)用sem_destroy后,不能再使用任何帶有sem的信號(hào)量函數(shù),除非通過(guò)調(diào)用sem_init重新初始化它。
3.int sem_wait(sem_t *sem)
int sem_trywait(sem_t *sem)
我們可以使用sem_wait或者sem_trywait函數(shù)來(lái)實(shí)現(xiàn)信號(hào)量的減1操作。使用sem_wait函數(shù)時(shí),如果信號(hào)量計(jì)數(shù)是0,就會(huì)發(fā)生阻塞。直到成功使信號(hào)量減1或者被信號(hào)中斷時(shí)才返回??梢允褂胹em_trywait來(lái)避免阻塞。調(diào)用sem_trywait時(shí),如果信號(hào)量是0,則不會(huì)阻塞,而是會(huì)返回-1,并將errno置為EAGAIN.
4.int sem_post(sem_t *sem)
我們可以調(diào)用它是信號(hào)量增1.
下面我們來(lái)看一段基于信號(hào)量的生產(chǎn)者消費(fèi)者模型:
#include <stdio.h>
#include <stdlib.h>
#include <pthread.h>
#include <semaphore.h>
#define _SIZE_ 20
int buf[_SIZE_];
sem_t blank;
sem_t data;
void *product(void *arg)
{
int index=0;
int count=0;
while(1)
{
sem_wait(&blank);//P
buf[index]=count++;
sleep(2);
sem_post(&data);//V
index++;
index %= _SIZE_;
}
}
void *consumer(void *arg)
{
int index=0;
int count=0;
while(1)
{
sem_wait(&data);
count=buf[index];
printf("consumer data:%d\n",count);
sem_post(&blank);
index++;
index %= _SIZE_;
}
}
int main()
{
sem_init(&blank,0,_SIZE_);
sem_init(&data,0,0);
pthread_t tid1,tid2;
pthread_create(&tid1,NULL,product,NULL);
pthread_create(&tid2,NULL,consumer,NULL);
pthread_join(tid1,NULL);
pthread_join(tid2,NULL);
sem_destroy(&blank);
sem_destroy(&data);
return 0;
}
運(yùn)行結(jié)果如下:
我們可以看到消費(fèi)者在不停的消費(fèi)生產(chǎn)者生產(chǎn)的數(shù)據(jù)、、、、、
網(wǎng)頁(yè)標(biāo)題:基于POSIX的信號(hào)量的生產(chǎn)者消費(fèi)者模型
文章鏈接:http://bm7419.com/article36/pccspg.html
成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián),為您提供微信小程序、軟件開(kāi)發(fā)、Google、ChatGPT、、網(wǎng)站改版
聲明:本網(wǎng)站發(fā)布的內(nèi)容(圖片、視頻和文字)以用戶(hù)投稿、用戶(hù)轉(zhuǎn)載內(nèi)容為主,如果涉及侵權(quán)請(qǐng)盡快告知,我們將會(huì)在第一時(shí)間刪除。文章觀點(diǎn)不代表本網(wǎng)站立場(chǎng),如需處理請(qǐng)聯(lián)系客服。電話(huà):028-86922220;郵箱:631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載,或轉(zhuǎn)載時(shí)需注明來(lái)源: 創(chuàng)新互聯(lián)