Linux 下c++多線程同步之信號量
- 2019 年 12 月 20 日
- 筆記
操作步驟:
1.創建信號量 函數: int semget(key_t _key ,int _nsems,int _semflg); _key 為整型值，用戶可以自己設定 _nsems 表示初始化信號量的個數。比如我們要創建一個信號量，則該值為1.,創建2個就是2。 _semflg ：信號量的創建方式或權限。有IPC_CREAT，IPC_EXCL。 IPC_CREAT如果信號量不存在，則創建一個信號量，否則獲取。 IPC_EXCL只有信號量不存在的時候，新的信號量才建立，否則就產生錯誤。
2.P操作(信號量值減一) 3.V操作(信號量值加一) 2和3步驟函數為: int semop(int semid ,struct sembuf *_sops ,size_t _nsops);
功能：用戶改變信號量的值。也就是使用資源還是釋放資源使用權。 返回值：成功返回0，失敗返回-1； 參數： _semid : 信號量的標識碼。也就是semget（）的返回值。 _sops是一個指向結構體數組的指針。 struct sembuf{ nsigned short sem_num;//第幾個信號量，第一個信號量為0 short sem_op;//對該信號量的操作。 short _semflg; }; sem_num: 操作信號在信號集中的編號。第一個信號的編號為0； sem_op : 如果其值為正數，該值會加到現有的信號內含值中。通常用於釋放所控資源的使用權；如果sem_op的值為負數，而其絕對值又大於信號的現值，操作將會阻塞，直到信號值大於或等於sem_op的絕通常用於獲取資源的使用權；如果 sem_op的值為0，則操作將暫時阻塞，直到信號的值變為0。 _semflg IPC_NOWAIT //對信號的操作不能滿足時，semop()不會阻塞，並立即返回，同時設定錯誤信息。 IPC_UNDO //程序結束時(不論正常或不正常)，保證信號值會被重設為semop()調用前的值。這樣做的目的在於避免程序在異常情況下結束時未將鎖定的資源解鎖，造成該資源永遠鎖定。 nsops：操作結構的數量，恆大於或等於1。
以上借鑒 信號量 Linux函數 semget();semctl();semop();
信號量阻塞案例
void debugPrint(char *objName, char *objAct, char *objState) { #ifdef DEBUG if (strlen(objAct) <= 20 && strlen(objAct) <= 15 && strlen(objAct) <= 10) { printf("%s::DEBUG %-25.20s %-20.15s %-10.10sn", POR_NAME, objName, objAct, objState); }else { printf("%s::DEBUG %-40.35s %-35.30s %-20.20sn", POR_NAME, objName, objAct, objState); } #endif } int sem_mutex = 0; void *semp_thread(void *param) { struct sembuf buf[] = {{0, -1, SEM_UNDO}}; semop(sem_mutex, buf, 1); debugPrint("semp_thread.sem_mutex", "semop P", "-1"); /* 線程結束後,傳值出去, 給pthread_join()的參數2 */ sleep(3); struct sembuf buf1[] = {{0, 1, SEM_UNDO}}; semop(sem_mutex, buf1, 1); debugPrint("semp_thread.sem_mutex", "semop V", "+1"); } // semphore int main() { sem_mutex = semget(123, 1, IPC_CREAT | 0666); union semun su; su.value = 1; semctl(sem_mutex, 0, SETVAL, su); // p操作 struct sembuf buf[] = {{0, -1, SEM_UNDO}}; semop(sem_mutex, buf, 1); debugPrint("main.sem_mutex", "semop P", "-1"); pthread_t semThreadID = NULL; pthread_create(&semThreadID, NULL, semp_thread, NULL); sleep(3); struct sembuf buf1[] = {{0, 1, SEM_UNDO}}; semop(sem_mutex, buf1, 1); debugPrint("main.sem_mutex", "semop V", "+1"); pthread_join(semThreadID, NULL); }
