理解 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.