歡迎來(lái)到裝配圖網(wǎng)! | 幫助中心 裝配圖網(wǎng)zhuangpeitu.com!
裝配圖網(wǎng)
ImageVerifierCode 換一換
首頁(yè) 裝配圖網(wǎng) > 資源分類 > DOC文檔下載  

進(jìn)程共享資源信號(hào)量控制詳細(xì)實(shí)現(xiàn)源碼及解釋

  • 資源ID:46843810       資源大小:95KB        全文頁(yè)數(shù):21頁(yè)
  • 資源格式: DOC        下載積分:0積分
快捷下載 游客一鍵下載
會(huì)員登錄下載
微信登錄下載
三方登錄下載: 微信開(kāi)放平臺(tái)登錄 支付寶登錄   QQ登錄   微博登錄  
二維碼
微信掃一掃登錄
下載資源需要0積分
郵箱/手機(jī):
溫馨提示:
用戶名和密碼都是您填寫的郵箱或者手機(jī)號(hào),方便查詢和重復(fù)下載(系統(tǒng)自動(dòng)生成)
支付說(shuō)明:
本站最低充值0.01積分,下載本資源后余額將會(huì)存入您的賬戶,您可在我的個(gè)人中心查看。
驗(yàn)證碼:   換一換

 
賬號(hào):
密碼:
驗(yàn)證碼:   換一換
  忘記密碼?
    
友情提示
2、PDF文件下載后,可能會(huì)被瀏覽器默認(rèn)打開(kāi),此種情況可以點(diǎn)擊瀏覽器菜單,保存網(wǎng)頁(yè)到桌面,就可以正常下載了。
3、本站不支持迅雷下載,請(qǐng)使用電腦自帶的IE瀏覽器,或者360瀏覽器、谷歌瀏覽器下載即可。
4、本站資源下載后的文檔和圖紙-無(wú)水印,預(yù)覽文檔經(jīng)過(guò)壓縮,下載后原文更清晰。
5、試題試卷類文檔,如果標(biāo)題沒(méi)有明確說(shuō)明有答案則都視為沒(méi)有答案,請(qǐng)知曉。

進(jìn)程共享資源信號(hào)量控制詳細(xì)實(shí)現(xiàn)源碼及解釋

信號(hào)量信號(hào)量(Semaphore)簡(jiǎn)單的說(shuō)就是用來(lái)控制多個(gè)進(jìn)程對(duì)共享資源使用的計(jì)數(shù)器。它是常被用作一種鎖定保護(hù)機(jī)制,當(dāng)某個(gè)進(jìn)程對(duì)資源進(jìn)行操作時(shí)阻止其他進(jìn)程對(duì)該資源的訪問(wèn)。需要注意的是,System V中的的信號(hào)量對(duì)象實(shí)際上是信號(hào)量的集合(set),它可以包含多個(gè)信號(hào)量,控制多個(gè)共享資源。有關(guān)的數(shù)據(jù)結(jié)構(gòu)和消息隊(duì)列一樣,我們?cè)诮榻B他的使用前先介紹一些相關(guān)的數(shù)據(jù)結(jié)構(gòu):1. sem前提提到,信號(hào)量對(duì)象實(shí)際是多個(gè)信號(hào)量的集合。在Linux系統(tǒng)中,這種集合是以數(shù)組的形式實(shí)現(xiàn)的。數(shù)組的每個(gè)成員都是一個(gè)單獨(dú)的信號(hào)量,它們?cè)谙到y(tǒng)中是以sem結(jié)構(gòu)的形式存儲(chǔ)的。Sem的結(jié)構(gòu)在Linux系統(tǒng)linux/sem.h中定義是這樣的:/* One semaphore structure for each semaphore in the system. */Struct sem Short sempid; /*pid of last operation*/ Ushort semval; /*current value*/ Ushort semncnt; /*num procs awaiting increase in semval*/ Ushort semzcnt; /*num procs awaiting semval=0*/;其中,Sem_pid成員保存了最近一次操作信號(hào)量進(jìn)程的pid。Sem_semval成員保存著信號(hào)量的計(jì)數(shù)值。Sem_semncnt成員保存著等待使用資源的進(jìn)程數(shù)目。Sem_semzcnt成員保存等待資源完全空閑的進(jìn)程數(shù)目。2.semunSemun聯(lián)合在senctl()函數(shù)中使用,提供senctl()操作所需要的信息。它在Linux系統(tǒng)linux/sem.h中定義是這樣的:/*arg for semctl system calls */Union semun Int val; /*value for SETVAL*/ Struct semid_ds *buf; /*buffer for IPC_STAT&SETALL*/ Ushort *array; /*array for GETALL&SETALL*/ Struct seminfo *_buf; /* buffer for IPC_INFO*/ Void *_pad;前三個(gè)參數(shù)在對(duì)senctl()函數(shù)介紹中會(huì)講到,這里暫時(shí)先不管它們。后兩個(gè)參數(shù)是Linux系統(tǒng)所獨(dú)有的,只是系統(tǒng)的內(nèi)核中使用。3. semufsemuf結(jié)構(gòu)被semop()函數(shù)(后面會(huì)講到)用來(lái)定義對(duì)信號(hào)量對(duì)象的基本操作。它在linux/sem.h中是這樣定義的:/*semop system calls takes an array of these.*/Stcuct sembuf Unsigned short sem_num; /*semaphore index in array*/ Short sem_op; /*semaphore operation*/ Short sem_flg; /*operation flags*/;其中,Sem_num 成員為接受操作的信號(hào)量在信號(hào)量數(shù)組中的序號(hào)(數(shù)組下標(biāo))。Sem_op成員定義了進(jìn)行的操作(可以是正,負(fù)和零)。Sem_flg是控制操作行為的標(biāo)志。如果sem_op是負(fù)值,就從指定的信號(hào)量中減去相應(yīng)的值。這對(duì)應(yīng)著獲取信號(hào)量所監(jiān)控 的資源操作。如果沒(méi)有sem_flg指定IPC_NOWAIT標(biāo)志,那么,當(dāng)現(xiàn)有的信號(hào)量數(shù)值小于sem_op的絕對(duì)值(表示現(xiàn)有的資源少于要獲取的資源)時(shí),調(diào)用semop()_函數(shù)的進(jìn)程就會(huì)被阻塞知道信號(hào)量的數(shù)值大于sem_op的絕對(duì)值(表示有足夠的資源被釋放)。 如果sem_op是正值,就在指定的信號(hào)量中加上相應(yīng)的值。這對(duì)應(yīng)著釋放信號(hào)量所監(jiān)控的資源 操作。如果sem_op是零,那么調(diào)用semop()函數(shù)的進(jìn)程就會(huì)被阻塞到直對(duì)應(yīng)的信號(hào)量值為零。這種操作的實(shí)質(zhì)就是等待信號(hào)量所監(jiān)控的資源被全部使用。利用這種資源操作可以動(dòng)態(tài)監(jiān)控資源的使用并調(diào)整資源的分配,避免不必要的等待。 4. Semid_qs 和msgqid_ds類似,semid_qs結(jié)構(gòu)被系統(tǒng)用來(lái)存儲(chǔ)每個(gè)信號(hào)量對(duì)象的有關(guān)信息。它在Linux系統(tǒng)庫(kù)linux/sem.h中是這樣定義的:/*One semid data structure for each set of semaphores in the system*/Struct semid_ds Struct ipc_perm sem_perm; /*permissions. see ipc.h*/ _kernel_time_t sem_otime; /*tast semop time*/ _kernel_time_t sem_ctime; /*last change time*/ Struct sem *sem_base; /*ptr to first semaphore in array*/ Struct sem_queue *sem_pending; /*pending oprations to be prosessed*/ Struct sem_queue *sem_pending_last; /*last pending opration*/ Struct sem_undo *undo; /*undo requests on this array*/ Unsigned short sem_nsems; /*no.of semaphores in array*/;其中Sem_perm成員保存了信號(hào)量對(duì)象的存取權(quán)限以及其他一些信息(見(jiàn)上面關(guān)于ipc_perm結(jié)構(gòu)的介紹)。Sem_otime成員保存了最近一次semop()操作的時(shí)間。Sem_ctime成員保存了信號(hào)量對(duì)象最近一次改動(dòng)發(fā)生的時(shí)間。Sem_base指針保存著信號(hào)量數(shù)組的起始地址。Sem_pending指針保存著還沒(méi)有進(jìn)行的操作。Sem_pending_last指針保存著最后一個(gè)還沒(méi)有進(jìn)行的操作。Sem_undo成員保存了undo請(qǐng)求的數(shù)目。Sem_nsems成員保存了信號(hào)量數(shù)組的成員數(shù)目。4.8.2有關(guān)的函數(shù)介紹完有關(guān)的數(shù)據(jù)結(jié)構(gòu),接下來(lái)我們將介紹使用信號(hào)量要用到的函數(shù):1.semget()使用semger()函數(shù)來(lái)建立新的信號(hào)量對(duì)象或者獲取已有的對(duì)象的標(biāo)示符。它在linux/sem.h 中的函數(shù)聲明是這樣的:系統(tǒng)調(diào)用:Semget()函數(shù)聲明:int semget(key_t key,int nsems,int semflg);返回值:semaphore set IPC identifier on success 1on error:errno=EACCESS(permission denied)權(quán)限不足 EEXIST(set exist,cannot create(IPC_EXCL)信號(hào)量已存在,無(wú)法創(chuàng)建 EIDRM(set is marked for deletion)信號(hào)量待刪 ENOENT(set does nor exisr,no IPC_CREAT was usrd)信號(hào)量不存在,無(wú)法打開(kāi) ENOMEM(Not enough memory to create new set)無(wú)足夠內(nèi)存以創(chuàng)建新信號(hào)量 ENOSPC(Maximun set limit exceeded)信號(hào)量個(gè)數(shù)已滿函數(shù)接受三個(gè)參數(shù)。其中第一個(gè)參數(shù)key和第三個(gè)參數(shù)semflg和前面講過(guò)的msgget()函數(shù)中的兩個(gè)參數(shù)對(duì)應(yīng)的,作用和取值的意義也相同,讀者可以參看msgget()的有關(guān)介紹。函數(shù)的第二個(gè)參數(shù)nsems是信號(hào)量對(duì)象所特有的。它指定了新生成的信號(hào)量對(duì)象中信號(hào)量的數(shù)目,也就是信號(hào)量數(shù)組成員的個(gè)數(shù)。在linux/sem.h定義了它的上限:#define SEMMSL 32 /*<=512 max num of semaphores per id */如果函數(shù)執(zhí)行的是打開(kāi)而不是創(chuàng)建操作,則這個(gè)參數(shù)被忽略。下面我們創(chuàng)建一個(gè)封裝函數(shù)作為本屆例子:Int open_semaphore_set(key_t keyval,int numsems) Int sid; If(!numsems) Return(-1);If(sid=semget(mykey,numsems,IPC_CREAT|0660)=-1) Return(-1);Return(sid)程序的分析請(qǐng)讀者自行完成。 2.semop()使用這個(gè)函數(shù)來(lái)改變信號(hào)量對(duì)象中各個(gè)信號(hào)量的狀態(tài)。它在Linux系統(tǒng)庫(kù)linux/sem.h中的函數(shù)聲明如下:系統(tǒng)調(diào)用:semop()函數(shù)聲明:int semop(int semid,struct sembuf*sops,unsig返回值:0 on success(all operations performed) -1 on error:errno=E2BIG(nsops greater than max number of ops allowedatomically)系統(tǒng)允許一次進(jìn)行的操作數(shù)小于 nsops EACCES(permission denied)權(quán)限不足 EAGAIN(IPC_NOWALT asserted,operation could not go through)操作不能進(jìn)行(IPC_NOWALT標(biāo)志是使用) EFAULT(invalid address pointed to by sops argument sops)地址非法 EIDRM(semaphore set was removed)信號(hào)量已被刪除 EINTR(Signal received while sleeping)阻塞被信號(hào)中止 EINVAL(set doesnt exist,or semid is invalid)信號(hào)量不存在或semid非法 ENOMEM(SEM_UNDO asserted,not enough memory to create the undo structure necessary)內(nèi)存不足,無(wú)法進(jìn)行undo操作(指定SEM_UNDO時(shí)) ERANGE(semaphore value out of range)信號(hào)量的值越界函數(shù)的第一個(gè)參數(shù)semid是要操作的信號(hào)量對(duì)象的標(biāo)示符。第二個(gè)參數(shù)sops是sembuf的數(shù)組,它定義了semop()函數(shù)所要進(jìn)行的操作序列。第三個(gè)參數(shù)nsops保存數(shù)組的長(zhǎng)度,也即semop()函數(shù)將進(jìn)行的操作個(gè)數(shù)。在前面對(duì)sembuf結(jié)構(gòu)的介紹中已經(jīng)介紹了semop()的各種基本操作。下面我們將結(jié)合例子對(duì)這些操作作進(jìn)一步的介紹。首先假設(shè)已經(jīng)通過(guò)semget()函數(shù)得到了一個(gè)只包含一個(gè)信號(hào)量的信號(hào)量對(duì)象,它在監(jiān)控著某臺(tái)最多能處理10分作業(yè)的打印機(jī)的使用。我們下面的操作都將是只針對(duì)這個(gè)信號(hào)量的。假設(shè)要向打印機(jī)交付一份作業(yè)。可以定義下面的sembuf變量來(lái)完成這個(gè)操作:Struct sembuf sem_get=0,-1,IPC_NOWAIT;它告訴系統(tǒng),將信號(hào)量對(duì)象中序號(hào)為零的信號(hào)量(第一個(gè)信號(hào)量)減一。IPC_NOWAIT標(biāo)志的定義告訴系統(tǒng),如果打印機(jī)的作業(yè)量(10份)已滿,則不阻塞進(jìn)程而是直接將控制權(quán)返回進(jìn)程并返回失敗信息。定義完操作后,我們使用下面的代碼來(lái)執(zhí)行它:If(semop(sid,&sem_get,1)=-1) Perror(“semop”);作業(yè)打印完成后,我們使用下面的sembuf變量來(lái)定義一個(gè)釋放資源的操作:Struct sembuf sem_release=0,1,IPC_NOWAIT;它告訴系統(tǒng)將信號(hào)量對(duì)象中序號(hào)為零的對(duì)象加一。然后用下面的代碼來(lái)完成這個(gè)操作:Semop(sid,&sem_release,1);這樣,我們就完成了一個(gè)完整的作業(yè)打印操作。3.semctl()函數(shù)和消息隊(duì)列的msgctl()函數(shù)類似,semctl()函數(shù)被用來(lái)直接對(duì)信號(hào)量對(duì)象進(jìn)行控制。它在linux/sem.h中的函數(shù)聲明如下:系統(tǒng)調(diào)用:semctl()函數(shù)聲明:int semctl(int semid,int semnum,int cmd,union semun arg); 返回值:positive integer on success -1 on error:errno=EACCESS(permission denied)權(quán)限不足 EFAUAL(semaphore set was removed)信號(hào)量已被刪除 EINVAL(set doesnt exist,or semid is invalid)信號(hào)量不存在或semid非法 EPERM(EUD hasno privileges for cmd in arg)無(wú)權(quán)進(jìn)行指定的操作 ENANGE(semaphore value out of range)信號(hào)量的值超界比較一下這兩個(gè)函數(shù)的參數(shù)我們會(huì)發(fā)現(xiàn)一些細(xì)微的差別。首先,因?yàn)樾盘?hào)量對(duì)象事實(shí)上是多個(gè)信息量的集合而非單一的個(gè)體,所以在進(jìn)行操作時(shí),不僅需要指定對(duì)象的標(biāo)示符。還需要用信號(hào)量在集合中的序號(hào)來(lái)指定具體的信號(hào)量個(gè)體。兩個(gè)函數(shù)都有cmd參數(shù),指定了函數(shù)進(jìn)行的具體操作。不過(guò),和msgctl()函數(shù)相比,semctl()函數(shù)可以盡心的操作要多得多:IPC_STAT取得信號(hào)量對(duì)象的semid_ds結(jié)構(gòu)信息,并將其存儲(chǔ)在arg參數(shù)中buf指針?biāo)竷?nèi)存中返回。IPC_SET用arg參數(shù)中buf的數(shù)據(jù)來(lái)設(shè)定信號(hào)量對(duì)象的semid-ds結(jié)構(gòu)信息。和消息隊(duì)列對(duì)象一樣,能被這個(gè)函數(shù)設(shè)定的只有少數(shù)幾個(gè)參數(shù)。IPC_RMID從內(nèi)存中刪除信號(hào)量對(duì)象。GETALL取得信號(hào)量對(duì)象中所有信號(hào)量的值,并存儲(chǔ)在arg參數(shù)中的array數(shù)組中返回。GETNCNT返回正在等待使用某個(gè)信號(hào)量所控制的資源進(jìn)程數(shù)目。GETPID返回最近一個(gè)對(duì)某個(gè)信號(hào)量調(diào)用semop()函數(shù)的進(jìn)程的pid.GEYVAL返回信號(hào)量的計(jì)數(shù)值。GETZCNT 返回正在等待某個(gè)信號(hào)量所控制資源全部使用的進(jìn)程數(shù)目。SETALL用arg參數(shù)中array數(shù)組的值來(lái)設(shè)定對(duì)象內(nèi)某個(gè)信號(hào)量的值。函數(shù)的第四個(gè)參數(shù)arg提供了操作所需要的其他信息。它的各個(gè)成員的意義在前面已經(jīng)有個(gè)介紹,這里不再贅述。需要強(qiáng)調(diào)的是它和msgctl()中的參數(shù)不一樣,是一個(gè)普通的變量而不是指針,初學(xué)者常常在這個(gè)問(wèn)題上犯錯(cuò)誤。下面舉幾個(gè)使用semctl()的例子。Int get_sem_val(Int sid,int semnum) return(semctl(sid,semnum,GETVAL,0);上面的代碼返回到信號(hào)量對(duì)象中某個(gè)信號(hào)來(lái)那個(gè)的值。注意這里semctl()函數(shù)的最后一個(gè)參數(shù)取的是零,這是因?yàn)閳?zhí)行GETVAL命令時(shí)這個(gè)參數(shù)被自動(dòng)忽略了。Void init_semaphore(int sid,int semnum,int initval) Union semun semopts; Semopts.val=initval; Semctl(sid,semum,SETVAL,semopts);上面的代碼用initval參數(shù)來(lái)設(shè)定信號(hào)量對(duì)象某個(gè)信號(hào)量的值。最后用一個(gè)例子來(lái)強(qiáng)調(diào)一個(gè)極易被忽視的錯(cuò)誤。在消息隊(duì)列和信號(hào)量對(duì)象中,都有IPC_STAT和IPC_SET的操作。但是由于傳遞參數(shù)的類型不同,造成了它們?cè)谑褂蒙系牟顒e。在msgctl()函數(shù)中,IPC_STAL 操作只是簡(jiǎn)單的將內(nèi)核中msfqid_ds結(jié)構(gòu)的地址賦予buf參數(shù)(是一個(gè)指針)。而在semctl()函數(shù)中,IPC_STAT操作是將semid_ds的內(nèi)容拷貝到arg參數(shù)的buf成員指針?biāo)傅膬?nèi)存中,所以,下面的代碼會(huì)產(chǎn)生錯(cuò)誤,而msgctl()函數(shù)的類似代碼卻不會(huì):Void getmode(int sid) Int rc; Union semun semops; /*下面的語(yǔ)句會(huì)產(chǎn)生錯(cuò)誤*/ If (rc=semctl(sid,0,IPC_STAT,semopts)=-1) Perror(“semctl”); Exit(1); Printf(“pemission mode were %on”,semopts.buf->sem_perm.mode); Return;為什么呢?一位現(xiàn)實(shí)沒(méi)有給buf指針?lè)峙鋬?nèi)存,其指向是不確定的。這種“不定向”的指針式c程序中最危險(xiǎn)的陷阱之一。改正這個(gè)錯(cuò)誤,只需要前提給buf指針準(zhǔn)備一塊內(nèi)存。下面是修改過(guò)的代碼:Void getmode(int sid) Int rc; Union semun sempots; Struct semid_ds mysemds; /*給buf指針準(zhǔn)備一塊內(nèi)存*/ Semopts.buf = &mysemds; /*現(xiàn)在ok了*/ If(rc=semctl(sid,0,IPC_STAT,semopts))=-1) Perror(“semctl”) Exit(1); Printf(“permission Mode were %on”,semopts.buf->sem_pem.mode); Return; 4.8.3信號(hào)量的實(shí)例1.背景知識(shí)Semtool工具通過(guò)命令行參數(shù)來(lái)決定它的行為,這樣它可以決定它的行為,這樣他可以被方便的應(yīng)用于shell腳本中。Semtool提供了和信號(hào)量有關(guān)的全部功能,包括創(chuàng)建信號(hào)量、操作、刪除信號(hào)量對(duì)象以及更改信號(hào)量權(quán)限等。使用它,我們可以在命令行上控制資源的共享。2.semtool的命令行語(yǔ)法建立信號(hào)量對(duì)象: semtool c (number of semaphores in set)鎖定信號(hào)量: semtool l(semaphore number to lock)解鎖信號(hào)量的鎖定: semtool u (semaphore number to unlock)改變信號(hào)量的權(quán)限: semtool m (mode)刪除信號(hào)量對(duì)象:semtool d3. semtool的使用舉例 Semtool c 5 Semtool 1 Semtool uSemtool m 660Semtool d4.semtool 的源代碼:Semtool程序的源代碼如下:#include<stdio.h>#incluude<ctype.h>#include<stdlib.h>#include<sys/types.h>#include<sys/ipc.h>#inlclude<sys/sem.h>#define SEM_RESOURCE_MAX 1 /*initial value of all semaphores(所有信號(hào)量的初始值)*/Void opensem(int *sid,key_t key);Void createsem(int *sid,key_t key,int members);Void locksem(int sid,int member);Void unloksem(int sid,int member);Void removesem(int sid);Unsigned short get_member_count(int sid);Int getval(int sid,int member);Void dispval(int sid,int member);Void changemode(int sid,char *mode);Void usage(void);Int main(int argc,char*argv) Key_t key; Int semset_id; If(argc=1) Usage(); /*Create unique key via call to ftok()(用ftok()函數(shù)創(chuàng)建關(guān)鍵字)*/ Key=ftok(“,”,s); Switch(tolower(argv10) Case c:if(argc!=3) Usage(); Createsem(&semset_id,key,atoi(argv2); Break; Casel:if(argc!=3) Usage(); Opensem(&semset_id,key); Locksem(semset_id,atoi(argv2); Break; Case u:if(argc!=3) Usage(); Opensem(&semset_id,key); Unlocksem(semset_id,atoi(arge2); Break; Cased:opensem(&semset_id,key); Removesem(semset_id); Break; Case m:opensem(&semset_id,key); Changemode(semset_id,argv2); Break; Default:usage(); Return(0);Void opensem(int*sid,key_t key) /*Open the semaphore set-do not create!(打開(kāi)信號(hào)量對(duì)象(而不是創(chuàng)建它))*/ If(*sid=semget(key,0,0666)=-1) Printf(“Semaphore set does not exist!n”); Exit(1); Void createsem(int*sid,key_t key,int members) Int cntr; Union semun semopts; If(members>SEMMSL) Prinff(“Sorry,max number of semaphores in a set is %dn”,SEMMSL); Exit(1); Printf(“Attempting to cteate new semaphore set with %d membersn”,members); If(*sid=semget(key,members,IPC_CREAIT|IPC_EXCL|0666)=-1) Fprintfs(stderr,”Semaphore set already exists!n”); Exit(1); Semots.val=SEM_RESOURCE_MAX; /*lnitialize all members (Could be done with SETALL)初始化對(duì)象內(nèi)所有信號(hào)量(該操作也可以用SETALL完成)*/For(cntr=0;cntr<members;cntr+) Semctl(*sid,cntr,SETVAL,semopts);Void locksem(int sid,int member) Struct sembuf sem_lock=0,-1,IPC_NOWALT;If(member<0|member>(get_member_cout(sid)-1) Fprintf(stderr,”semaphore member%d out of rangn”,member); Return;/*Attempt to luck the semaphore set 嘗試鎖定信號(hào)量*/If(!getvala(sid,member) Fprintf(stderr,”semaphore member%d ouot of rangn”,member); Return;/*Attnmpt to lock the semphore set嘗試鎖定信號(hào)量*/If(!getval(sid,member)) Fprintf(stderr,”Semaphore resources exhausted (no lock)!n”); Exit(1);Sem_lock.sem_num=member; If(semop(sid,&sem_lock,1)=-1) Fprintff(stderr,”Lock faildn”); Exit(1);Else Printf(“Semaphore resources decrememted by one(lockd)n”);Dispval(sid,member);Void unlocksem(int sid,int member) Struct sembuf sem_unlock=member,1,IPC_NOWALT; Int semval; If(member<0|member>(get_member_count(sid)-1) Fprintf(stderr,”semaphore member%d out of rangn”,member); Return;/*Is the semaphore set locked?判斷信號(hào)量是否被鎖*/Semval=getval(sid,member);If(semval=SEM_RESOURCE_MAX) Fprintf(stderr,”Semaphore not locked!n”);Exit(1); Sem_unlock,sem_num=member;/*Attempt to lock the semaphore set 嘗試解除鎖定*/If(semop(sid,&sem_unlock,1)=-1) Fprintf(stderr,”Unlock failedn”); Exit(1);Else Printf(“Semaphore resources incremented by one(unlocked)n”; Dispval(sid,member);Void removesem(int sid) Semctl(sid,0,IPC_RMID,0); Printf(“Semaphore removedn”);Unsigned short ger_member_cout(int sid) Union semun semots; Struct semid_ds mysemds; Semopts.buf=&mysemds; /*Return number of menbers in the semaphore set(返回對(duì)象內(nèi)的信號(hào)量個(gè)數(shù))*/ Return(semopts.buf->sem_nsems);Int getval(int sid,int member) Int semval; Semval=semctl(sid,member,GETVAL.0); Return(semval);Void changemode(int sid,char*mode) Int rc; Union semun semopts; Struct semid_ds mysemds;/*Get current values for internal data structure(獲取對(duì)象當(dāng)前的狀態(tài))*/Semopts.buf =&mysemds;Rc=semctl(sid,0,IPC_STAT,semopts);If(rc=-1) Perror(“semctl”); Exit(1);Printf(“Old permissions were%on”,semopts,buf->sem_perm.mode);/*change the permissions on the semaphore(讀取信號(hào)量對(duì)象的權(quán)限)*/Sscanf(mode,”%ho”,&sempot.buf->sem_pem.mode);/*Update the internal data structure更新權(quán)限*/Semctl(sid,0,IPC_SET,semopts);Printf(Updatedn”);Void dispval(int sid,int member) Int semval; Semval=semctl(sid,member,GETVAL,0); Printf(“semval for member%dn”,member,semval);Void usage(void) Fprintf(“stderr,”semtool-A utility for thikering with semaphoresn”); Fprintf(“stderr,”Nusage:semtool4(c)reate<semcout>n”); Fprintf(stderr,” (l)ock<sem#>n”); Fprintf(stderr,” (u)nlock<sem#>n”); Fprintf(stderr,” (d)eleten”); Fprintf(stderr,” (m)ode<mode>n”); Exit(1);4.9共享內(nèi)存共享內(nèi)存(Shared Memory)簡(jiǎn)單的說(shuō)就是被多個(gè)進(jìn)程共享的內(nèi)存。它在各種進(jìn)程通信方法中是最快的,因?yàn)樗鼘⑹切畔⒅苯佑成涞絻?nèi)存中,省去了其他IPC方法的中間步驟。4.9.1有關(guān)的數(shù)據(jù)機(jī)構(gòu)下面我們介紹幾個(gè)和共享內(nèi)存有關(guān)的數(shù)據(jù)結(jié)構(gòu):1.shmid_ds和前面介紹的兩個(gè)IPC對(duì)象一樣,共享內(nèi)存也有一個(gè)給系統(tǒng)內(nèi)存用來(lái)保存相關(guān)信息的結(jié)構(gòu),就是shmid_ds.它在 linux/shm.h中的定義是這樣的: Struct shmid_ds Struct ipc_perm shm_perm; /*operation perms*/ Int shm_segsz; /*size of segment (bytes)*/ _kernel_time_t shm_atime: /*last attach time*/ _kernel_time_t shm_dtime: /*last detach time*/ _kernel_time_t shm_ctime; /*last change time*/ _kernel_ipc_pid_t shm_cpid; /*pid of creator*/ _kernel_ipc_pid_t shm_lpid; /*pid of creator*/ Unsigned short shm_nattch; /*no.of current attaches*/ Unsigned short shm_unused; /.*compatibility*/ Void *shm_unused2; /*ditto-used by DIPC*/ Void *shm_unused3; /*unused*/ 其中,Shm_perm成員保存了共享內(nèi)存對(duì)象的存取權(quán)限及其他一些信息。Shm_segze成員定義了共享內(nèi)存大?。ㄒ宰止?jié)胃單位)Shm_atime成員保存了最近一次進(jìn)程連接共享內(nèi)存的時(shí)間。Shm_dtime成員保存了最近一次進(jìn)程斷開(kāi)與共享內(nèi)容的連接時(shí)間。Shm_ctime成員保存了最近一次shmid_ds結(jié)構(gòu)內(nèi)容改變的時(shí)間Shm_cpid成員保存了創(chuàng)建共享內(nèi)容的進(jìn)程pidShm_lpid成員保存了最近一次連接共享內(nèi)存的進(jìn)程pid.Shm_nattch成員保存了與共享內(nèi)存連接的進(jìn)程數(shù)目。剩下的三個(gè)成員被內(nèi)核保留使用,這里就不介紹了。4.9.2有關(guān)的函數(shù)接下來(lái)我們介紹和共享內(nèi)存有關(guān)的函數(shù):1Sys_shmgrt()函數(shù)使用shmget()函數(shù)來(lái)創(chuàng)建新的獲取得已有的共享內(nèi)存。它在Linux系統(tǒng)linux/shm.h中的定義是這樣的:系統(tǒng)調(diào)用:shmget()函數(shù)聲明:int shmget(key_t key,int size,int shmflg); 返回值:shared memory segment identifier on success -1 on error:errno=EINVAL(lnvalid segment size specified指定的共享內(nèi)存大小非法) EEXIST(Segment exists,cannot create共享內(nèi)存已存在,無(wú)法創(chuàng)建) EIDRM(Segment is marked for deletion,or was remove共享內(nèi)存待刪或已刪) ENOENT(Segment does not exist共享內(nèi)存不存在,無(wú)法打開(kāi)) EACCES(Permission denied權(quán)限不足) ENOMEM(Not enough memory to create segment 內(nèi)存不足,無(wú)法創(chuàng)建共享內(nèi)存)和前面兩個(gè)IPC對(duì)象函數(shù)一樣,shmget()函數(shù)的第一個(gè)參數(shù)key是共享內(nèi)存的關(guān)鍵字;第二個(gè)參數(shù)size是創(chuàng)建的共享內(nèi)存的大小,以字節(jié)為單位。第三個(gè)參數(shù)shmflg是控制函數(shù)行為的標(biāo)志量,其取值的含義與作用和msgget()及semget()函數(shù)的對(duì)應(yīng)參數(shù)都是相同的,這里不再贅述。如果操作成功,函數(shù)返回共享內(nèi)存的標(biāo)識(shí)符。下面的代碼示范了shmger()函數(shù)的使用: Int open_shm(key_t keyval,int segsize) Int shmid:If(shmid=shmget(keyval,segsize,IPC_CREAT|0660)=-1) Return(-1); Return(shmid);2.shmat()函數(shù)當(dāng)一個(gè)進(jìn)程使用shmget()函數(shù)得到了共享內(nèi)存的標(biāo)志符之后,就可以使用shmat()函數(shù)將共享內(nèi)存映射到進(jìn)程自己的內(nèi)存空間內(nèi)。Shmat()函數(shù)在linux系統(tǒng)函數(shù)庫(kù)linux/shm.h中的函數(shù)聲明如下:系統(tǒng)調(diào)用:shmat()函數(shù)聲明:int shmat (int shmid,char *shmaddr,int shmflg); 返回值:address at which segment was attached to the process,or -1 on error:ereno =EINVAL(invalid IPC ID value or attach address passed)指定的IPC標(biāo)識(shí)符或內(nèi)存地址非法 ENODMEM(Not enough memory to attach segment)內(nèi)存不足 EACCES(permission denied)權(quán)限不足 第一個(gè)參數(shù)是共享內(nèi)存的標(biāo)識(shí)符。第二個(gè)參數(shù)shmadar指定了共享內(nèi)存映射的地址。因?yàn)檫@樣必須要預(yù)先分配內(nèi)存,十分不便,所以我們?cè)谑褂脮r(shí)常常將這個(gè)參數(shù)置零,這樣系統(tǒng)會(huì)自動(dòng)為映射分配一塊未使用的內(nèi)存。如果指定了地址,可以給第三個(gè)參數(shù)shmflg指定SHM_RND標(biāo)志來(lái)強(qiáng)迫將內(nèi)存大小設(shè)定為頁(yè)面的尺寸.。如果指定了SHM_RDONLY參數(shù),共享內(nèi)存將被映射成只讀。映射成功后,函數(shù)返回指向映射內(nèi)存的指針。下面的這段代碼演示了shmat()函數(shù)的使用:Char*attach_segment(int shmid) Return(shmat(shmid,0,0);得到了映射內(nèi)存的指針之后,我們就可以像讀寫普通內(nèi)存一樣對(duì)共享內(nèi)存進(jìn)行讀寫了。3.shmctl()函數(shù)和前兩個(gè)IPC對(duì)象一樣,共享內(nèi)存也有一個(gè)直接對(duì)其進(jìn)行操作的函數(shù),就是shmctl()函數(shù)。它在Linux系統(tǒng)函數(shù)庫(kù)linux/shm.h中的函數(shù)聲明是這樣的:系統(tǒng)調(diào)用:shmctl()函數(shù)聲明:int shmctl(int shmqid,int cmd,struct shmid_ds*buf); 返回值:0 on success -1 on error;errno=EACCES(No read permission and cmd is IPC_STAT進(jìn)行IPC_STAT)操作時(shí)無(wú)讀權(quán) EFAULT(Address pointed to by buf is invalid with IPC_SETandIPC_STAT commands buf)指定的地址非法 EIDRM(segment was removed during retrieval)操作過(guò)程中共享內(nèi)存被刪除 EINVAL(shmqid invalid shmqid)非法 EPERM(IPC_SET or IPC_RMID command was issued,but calling process does not have write(alter)access to the segment)進(jìn)程無(wú)寫全這個(gè)函數(shù)和msgger()函數(shù)十分相似,用法也相同。它支持的操作有:IPC_STAT 獲得共享內(nèi)存的信息。IPC_SET 設(shè)定共享內(nèi)存的信息。IPC_RMID 刪除共享內(nèi)存。需要說(shuō)明的是,當(dāng)執(zhí)行IPC-RMID操作時(shí),系統(tǒng)并不是立即將其刪除,而只是將其標(biāo)為待刪,然后等待與其連接的進(jìn)程斷開(kāi)連接。只有當(dāng)所有的連接都斷開(kāi)以后系統(tǒng)才執(zhí)行真正的刪除操作。當(dāng)然,如果執(zhí)行IPC_RMID的時(shí)候沒(méi)有任何連接,刪除將是立即執(zhí)行的。4.shmdt()函數(shù) 當(dāng)一個(gè)進(jìn)程不再需要某個(gè)共享內(nèi)存的映射時(shí),就應(yīng)該使用

注意事項(xiàng)

本文(進(jìn)程共享資源信號(hào)量控制詳細(xì)實(shí)現(xiàn)源碼及解釋)為本站會(huì)員(痛***)主動(dòng)上傳,裝配圖網(wǎng)僅提供信息存儲(chǔ)空間,僅對(duì)用戶上傳內(nèi)容的表現(xiàn)方式做保護(hù)處理,對(duì)上載內(nèi)容本身不做任何修改或編輯。 若此文所含內(nèi)容侵犯了您的版權(quán)或隱私,請(qǐng)立即通知裝配圖網(wǎng)(點(diǎn)擊聯(lián)系客服),我們立即給予刪除!

溫馨提示:如果因?yàn)榫W(wǎng)速或其他原因下載失敗請(qǐng)重新下載,重復(fù)下載不扣分。




關(guān)于我們 - 網(wǎng)站聲明 - 網(wǎng)站地圖 - 資源地圖 - 友情鏈接 - 網(wǎng)站客服 - 聯(lián)系我們

copyright@ 2023-2025  zhuangpeitu.com 裝配圖網(wǎng)版權(quán)所有   聯(lián)系電話:18123376007

備案號(hào):ICP2024067431號(hào)-1 川公網(wǎng)安備51140202000466號(hào)


本站為文檔C2C交易模式,即用戶上傳的文檔直接被用戶下載,本站只是中間服務(wù)平臺(tái),本站所有文檔下載所得的收益歸上傳人(含作者)所有。裝配圖網(wǎng)僅提供信息存儲(chǔ)空間,僅對(duì)用戶上傳內(nèi)容的表現(xiàn)方式做保護(hù)處理,對(duì)上載內(nèi)容本身不做任何修改或編輯。若文檔所含內(nèi)容侵犯了您的版權(quán)或隱私,請(qǐng)立即通知裝配圖網(wǎng),我們立即給予刪除!