一、什麼是信號量
就是一種用來描述某種資源數量個數的計數器,透過控制其他通訊資源來實現進程通訊。它在過程中負責資料的互斥、同步等。互斥,就是在同一時間段內,A、B兩個行程只有一個行程在運作。同步。就是A 進程完成之後,B進程接著完成,有一定的執行順序。
二、工作原理
兩種操作模式,P操作和V操作。
P操作(就是申請資源,信號量進行減一操作)
V操作(釋放資源,信號量進行加一操作)
三、 ipcs -s 查看semid
ipcrm -s id 刪除id
四、主要函數
shmget 建立信號量
shmctl 刪除
shmop P/V 操作
shmctl 刪除
shmop P/V 操作
shmctl 刪除
shmop P/V 操作
函數原型: int semop(int sem_id,struct sembuf *sops,size_t nsops);
struct sembuf { unsigned short sem_num;//sem_num是信号集中的索引,0代表第一个,1,代表第二个。。。 short sem_op; //操作类型,1 -->V操作,-1-->P操作 short sem_flg; //操作标志 };
nsops 就是sops 的個數
~~ ~~~~~~~~~~ ~~~~********** man 函數名稱可查看函數的用法******** **~~~~~~~~~~~~~~~~~~~
五、程式碼實作
comm.h#pragma once #include<stdio.h> #include<stdlib.h> #include<unistd.h> #include<sys/types.h> #include<sys/ipc.h> #include<sys/sem.h> #define _PATH_ "." #define _PROG_ID_ 0x6675 union semun { int val; struct semid_ds *buf; unsigned short *array; struct seminfo *__buf; }; int creatSem(int nsems); int get_Sem(); int initSem(int sem_id,int Which); int destroySem(int sem_id); int V_Sem(int sem_id,int which); int P_Sem(int sem_id,int which); static int op_Sem(int sem_id,int op,int which);
#include"comm.h" int creatSem(int nsems) { key_t _key=ftok(_PATH_,_PROG_ID_); if(_key<0) { perror("ftok"); return -1; } umask(0); int sem_Flg=IPC_CREAT|IPC_EXCL|0666; int sem_id=semget(_key,nsems,sem_Flg); if(sem_id<0) { perror("semget"); return -1; } return sem_id; } int get_Sem() { key_t k=ftok(_PATH_,_PROG_ID_); return semget(k,0,0); } static int op_Sem(int sem_id,int op,int which) { struct sembuf sem; sem.sem_num=which; sem.sem_op=op; sem.sem_flg=0; return semop(sem_id,&sem,1); } int initSem(int sem_id,int Which) { union semun _semum; _semum.val=1; int ret= semctl(sem_id,Which,SETVAL,_semum); if(ret==-1) { perror("semctl"); return ret; } return ret; } int P_Sem(int sem_id,int which) { int ret=op_Sem(sem_id,-1,which); if(ret==-1) { perror("p_sem"); return -1; } return ret; } int V_Sem(int sem_id,int which) { int ret=op_Sem(sem_id,1,which); if(ret==-1) { perror("V_Sem"); return ret; } return ret; } int destroySem(int sem_id) { int ret=semctl(sem_id,0,IPC_RMID,NULL); if(ret==-1) { perror("semtrl"); return -1; } return ret; }
my_shm.c
#include"comm.h" int main() { int sem_id=creatSem(1); initSem(sem_id,0); pid_t id=fork(); if(id<0) { perror("for"); return -1; } else if(id==0) { int sem_id=get_Sem(); while(1) { P_Sem(sem_id,0); printf("A"); fflush(stdout); sleep(1); printf("A"); fflush(stdout); sleep(2); V_Sem(sem_id,0); } }else { while(1) { P_Sem(sem_id,0); printf("B"); fflush(stdout); sleep(1); printf("B"); fflush(stdout); sleep(1); V_Sem(sem_id,0); } waitpid(id,NULL,0); } }
在信號量之前(如下圖)可以看出列印結果是隨機的。