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); }
