1.信號量
信號量本質上是一個計數器(不設置全局變量是因為進程間是相互獨立的,而這不一定能看到,看到也不能保證++引用計數為原子操作),用於多進程對共享數據對象的讀取,它和管道有所不同,它不以傳送數據為主要目的,它主要是用來保護共享資源(信號量也屬於臨界資源),使得資源在一個時刻只有一個進程獨享。
2.信號量的工作原理
由於信號量只能進行兩種操作等待和發送信號,即P(sv)和V(sv),他們的行為是這樣的:
(1)P(sv):如果sv的值大於零,就給它減1;如果它的值為零,就掛起該進程的執行
(2)V(sv):如果有其他進程因等待sv而被掛起,就讓它恢復運行,如果沒有進程因等待sv而掛起,就給它加1.
在信號量進行PV操作時都為原子操作(因為它需要保護臨界資源)
注:原子操作:單指令的操作稱為原子的,單條指令的執行是不會被打斷的
3.二元信號量
二元信號量(Binary Semaphore)是最簡單的一種鎖(互斥鎖),它只用兩種狀態:占用與非占用。所以它的引用計數為1。
4.進程如何獲得共享資源
(1)測試控制該資源的信號量
(2)信號量的值為正,進程獲得該資源的使用權,進程將信號量減1,表示它使用了一個資源單位
(3)若此時信號量的值為0,則進程進入掛起狀態(進程狀態改變),直到信號量的值大於0,若進程被喚醒則返回至第一步。
注:信號量通過同步與互斥保證訪問資源的一致性。
5.與信號量相關的函數
所有函數共用頭文件
#include <sys/types.h> #include <sys/ipc.h> #include <sys/sem.h>
5.1創建信號量
int semget(key_t key,int nsems,int flags)
//返回:成功返回信號集ID,出錯返回-1
(1)第一個參數key是長整型(唯一非零),系統建立IPC通訊 ( 消息隊列、 信號量和 共享內存) 時必須指定一個ID值。通常情況下,該id值通過ftok函數得到,由內核變成標識符,要想讓兩個進程看到同一個信號集,只需設置key值不變就可以。
(2)第二個參數nsem指定信號量集中需要的信號量數目,它的值幾乎總是1。
(3)第三個參數flag是一組標志,當想要當信號量不存在時創建一個新的信號量,可以將flag設置為IPC_CREAT與文件權限做按位或操作。
設置了IPC_CREAT標志后,即使給出的key是一個已有信號量的key,也不會產生錯誤。而IPC_CREAT | IPC_EXCL則可以創建一個新的,唯一的信號量,如果信號量已存在,返回一個錯誤。一般我們會還或上一個文件權限
5.2刪除和初始化信號量
int semctl(int semid, int semnum, int cmd, ...);
如有需要第四個參數一般設置為union semnu arg;定義如下
union semun
{
int val; //使用的值
struct semid_ds *buf; //IPC_STAT、IPC_SET 使用的緩存區
unsigned short *arry; //GETALL,、SETALL 使用的數組
struct seminfo *__buf; // IPC_INFO(Linux特有) 使用的緩存區
};
(1)sem_id是由semget返回的信號量標識符
(2)semnum當前信號量集的哪一個信號量
(3)cmd通常是下面兩個值中的其中一個
SETVAL:用來把信號量初始化為一個已知的值。p 這個值通過union semun中的val成員設置,其作用是在信號量第一次使用前對它進行設置。
IPC_RMID:用於刪除一個已經無需繼續使用的信號量標識符,刪除的話就不需要缺省參數,只需要三個參數即可。
5.3改變信號量的值
int semop(int semid, struct sembuf *sops, size_t nops);
(1)nsops:進行操作信號量的個數,即sops結構變量的個數,需大於或等於1。最常見設置此值等於1,只完成對一個信號量的操作
(2)sembuf的定義如下:
struct sembuf{
short sem_num; //除非使用一組信號量,否則它為0
short sem_op; //信號量在一次操作中需要改變的數據,通常是兩個數,
//一個是-1,即P(等待)操作,
//一個是+1,即V(發送信號)操作。
short sem_flg; //通常為SEM_UNDO,使操作系統跟蹤信號量,
//並在進程沒有釋放該信號量而終止時,操作系統釋放信號量
};
5.4sembuf中sem_flg的設置問題
通常設置為SEM_UNDO,使操作系統跟蹤信號量, 並在進程沒有釋放該信號量而終止時,操作系統釋放信號量 ,例如在二元信號量中,你不釋放該信號量 而異常退出,就會導致別的進程一直申請不到信號量,而一直處於掛起狀態。
是否設置sem_flg為SEM_UNDO的區別

6.模擬實現信號量實現進程間通信
用一個上課的時候講過的簡單的例子來說明一下:
#include <stdio.h>
#include <stdlib.h>
#include <semaphore.h>
#include <errno.h>
#define total 20
sem_t remain, apple, pear, mutex;
static unsigned int vremain = 20, vapple = 0, vpear = 0;
void *father(void *);
void *mather(void *);
void *son(void *);
void *daughter(void *);
void print_sem();
int main()
{
pthread_t fa, ma, so, da;
sem_init(&remain, 0, total);//總數初始化為20
sem_init(&apple, 0, 0);//盆子中蘋果數, 開始為0
sem_init(&pear, 0, 0);//盆子中梨子數, 開始為0
sem_init(&mutex, 0, 1);//互斥鎖, 初始為1
pthread_create(&fa, NULL, &father, NULL);
pthread_create(&ma, NULL, &mather, NULL);
pthread_create(&so, NULL, &son, NULL);
pthread_create(&da, NULL, &daughter, NULL);
for(;;);
}
void *father(void *arg)
{
while(1)
{
sem_wait(&remain);
sem_wait(&mutex);
printf("父親: 放蘋果之前, 剩余空間=%u, 蘋果數=%u\n", vremain--, vapple++);
printf("父親: 放蘋果之后, 剩余空間=%u, 蘋果數=%u\n", vremain, vapple);
sem_post(&mutex);
sem_post(&apple);
sleep(1);
}
}
void *mather(void *arg)
{
while(1)
{
sem_wait(&remain);
sem_wait(&mutex);
printf("母親: 放梨子之前, 剩余空間=%u, 梨子數=%u\n", vremain--, vpear++);
printf("母親: 放梨子之后, 剩余空間=%u, 梨子數=%u\n", vremain, vpear);
sem_post(&mutex);
sem_post(&pear);
sleep(2);
}
}
void *son(void *arg)
{
while(1)
{
sem_wait(&pear);
sem_wait(&mutex);
printf("兒子: 吃梨子之前, 剩余空間=%u, 梨子數=%u\n", vremain++, vpear--);
printf("兒子: 吃梨子之后, 剩余空間=%u, 梨子數=%u\n", vremain, vpear);
sem_post(&mutex);
sem_post(&remain);
sleep(3);
}
}
void *daughter(void *arg)
{
while(1)
{
sem_wait(&apple);
sem_wait(&mutex);
printf("女兒: 吃蘋果之前, 剩余空間=%u, 蘋果數=%u\n", vremain++, vapple--);
printf("女兒: 吃蘋果之前, 剩余空間=%u, 蘋果數=%u\n", vremain, vapple);
sem_post(&mutex);
sem_post(&remain);
sleep(3);
}
}
void print_sem()
{
int val1, val2, val3;
sem_getvalue(&remain, &val1);
sem_getvalue(&apple, &val2);
sem_getvalue(&pear, &val3);
printf("Semaphore: remain:%d, apple:%d, pear:%d\n", val1, val2, val3);
}
編譯時記得要加上 -lpthread 否則sem_ 都是未定義的。
因為在主函數中做了一個死循環所以這個程序會一直跑下去

