怎么看待Linux 多線程中的信號量Semaphore

今天就跟大家聊聊有關怎么看待Linux 多線程中的信號量Semaphore，可能很多人都不太了解，為了讓大家更加了解，小編給大家總結了以下內容，希望大家根據這篇文章可以有所收獲。

理解 Semaphore，從一個好的翻譯開始

Semaphore，對多線程有過了解的人都聽說過，一般我們解釋為“信號量”。可是，這個單詞對我們來說還是比較陌生，它和另一個單詞  Singal(信號)什么關系呢?想要真正理解這個概念，必須得從它的翻譯開始。事實上，Semaphore  最好的翻譯應該為“信號計數量”，承認了這一點，想必你也清楚了：它和 Signal 不是一回事!

劍橋詞典翻譯，并不容易理解

信號：簡單來說就是消息，是由用戶、系統或者進程發送給目標進程的信息，用來通知目標進程某個狀態的改變或系統異常，對應的是異步的場景(我之前的文章有詳細介紹過)。

信號量：首先是一個變量，其次是計數器。它是多線程環境下使用的一種設施，信號量在創建時需要設置一個初始值，表示同時可以有幾個任務(線程)可以訪問某一塊共享資源。

• 一個任務要想訪問共享資源，前提是信號量大于0，當該任務成功獲得資源后，將信號量的值減 1;

• 若當前信號量的值小于 0，表明無法獲得信號量，該任務必須被掛起，等待信號量恢復為正值的那一刻;

• 當任務執行完之后，必須釋放信號量，對應操作就是信號量的值加 1。

另外，對信號量的操作(加、減)都是原子的。互斥鎖(Mutex)就是信號量初始值為 1 時的特殊情形，即同時只能有一個任務可以訪問共享資源區。

Semaphore 再理解

我們來設想這樣一個場景(上圖)：假如北京的國家大劇院有一場免費的音樂會演出，可是現在正值疫情期間，劇院規定：劇院觀眾總人數要限制，但是允許大家中途退場，把票給其他人，其他人可以中途進場。于是，第一批先到的人從劇院門口票箱中取到了票，然后進場欣賞演出。后到的人就因為劇院滿了，在門口等待。過了一段時間，有人嫌節目太無聊了，提前退場了，退場時他把門票放回去了。這樣，其他人拿著這個人的票進場了。隨后，又有人退場了，但是他忘記把票放回去了。這也沒關系，大不了劇院內可容納的總人數少了一個罷了。

上面的例子中，音樂會現場就是一塊共享資源區，觀眾就是任務(線程)，而票箱中的門票數就是信號量。信號量用作并發量限制，由于總的門票數是固定的，所以不會出現音樂廳被擠爆的情況。

上述的例子中，我們允許退場的觀眾把票帶走，這是為什么呢?因為劇院工作人員可以隨時在票箱里補充些門票呀(線程生產者)。說到這，你們是不是有點似曾相識呀?對啰，就是線程池，但還是有些不同，你們自己品味吧。

Semaphore 實操練習

信號量類型為 sem_t，類型及相關操作定義在頭文件 semaphore.h 中，

創建信號量

int sem_init(sem_t *sem, int pshared, unsigned int value);

信號量的值加 1

int sem_post(sem_t *sem);

信號量的值減 1

int sem_wait(sem_t *sem);

信號量銷毀

int sem_destroy(sem_t *sem);

具體參數含義及返回值，這里就不贅述了。下面展示了一個例子：

你總共有三種類型的下載任務(類型 id 為 1、2、3)，每次從鍵盤讀取一種類型的任務進行下載，但是 CPU 最多可以同時執行 2  個下載任務(創建兩個線程)。

#include <stdio.h> #include <pthread.h> #include <semaphore.h> #define MAXNUM (2) sem_t semDownload; pthread_t a_thread, b_thread, c_thread; int g_phreadNum = 1;  void func1(void *arg) {     // 等待信號量的值 > 0     sem_wait(&semDownload);     printf("============== Downloading taskType 1 ============== \n");     sleep(5);     printf("============== Finished taskType 1 ============== \n");     g_phreadNum--;     // 等待線程結束     pthread_join(a_thread, NULL); }  void func2(void *arg) {     sem_wait(&semDownload);     printf("============== Downloading taskType 2 ============== \n");     sleep(3);     printf("============== Finished taskType 2 ============== \n");     g_phreadNum--;     pthread_join(b_thread, NULL); }  void func3(void *arg) {     sem_wait(&semDownload);     printf("============== Downloading taskType 3 ============== \n");     sleep(1);     printf("============== Finished taskType 3 ============== \n");     g_phreadNum--;     pthread_join(c_thread, NULL); }  int main() {     // 初始化信號量     sem_init(&semDownload, 0, 0);     int taskTypeId;     while (scanf("%d", &taskTypeId) != EOF)     {         // 輸入 0, 測試程序是否能正常退出         if (taskTypeId == 0 && g_phreadNum <= 1)         {             break;         } else if (taskTypeId == 0)         {             printf("Can not quit, current running thread num is %d\n", g_phreadNum - 1);         }         printf("your choose Downloading taskType %d\n", taskTypeId);         // 線程數超過 2 個則不下載         if (g_phreadNum > MAXNUM)         {             printf("!!! You've reached the max number of threads !!!\n");             continue;         }         // 用戶選擇下載 Task         switch (taskTypeId)         {         case 1:             // 創建線程 1             pthread_create(&a_thread, NULL, func1, NULL);             // 信號量 + 1，進而觸發 func1 的任務             sem_post(&semDownload);             // 總線程數 + 1             g_phreadNum++;             break;         case 2:             pthread_create(&b_thread, NULL, func2, NULL);             sem_post(&semDownload);             g_phreadNum++;             break;         case 3:             pthread_create(&c_thread, NULL, func3, NULL);             sem_post(&semDownload);             g_phreadNum++;             break;         default:             printf("!!! error taskTypeId %d !!!\n", taskTypeId);             break;         }     }     // 銷毀信號量     sem_destroy(&semDownload);     return 0; }

上述例子中，采用了 pthread_join()  的方式，即子線程合入主線程，主線程阻塞等待子線程結束，然后回收子線程資源。而線程加入還有另外一種方式：pthread_detach()，即主線程與子線程分離，主線程不用關注子線程什么時候結束，子線程結束后，資源自動回收。

程序運行結果如下：

還要注意一點：pthread.h 非 linux 系統的默認庫， gcc 編譯參數需要手動添加選項：-lpthread、-pthread.

看完上述內容，你們對怎么看待Linux 多線程中的信號量Semaphore有進一步的了解嗎？如果還想了解更多知識或者相關內容，請關注億速云行業資訊頻道，感謝大家的支持。