php進程通信之信號量淺析介紹

常見進程通信方式

一些理論基礎

  • 臨界資源:每次僅允許一個進程訪問的資源。
  • 臨界區:每個進程中訪問臨界資源的那段代碼叫臨界區

所謂臨界區(也稱為臨界段)就是訪問和操作共享數據的代碼段。

進程互斥:兩個或以上的進程不能同時進入關於同一組共享變量的臨界區域,即一個進程正在訪問臨界資源,另一個進程要想訪問必須等待。

進程同步:主要研究如何確定數個進程之間的執行順序和避免數據競爭的問題 即,如何讓多個進程能一塊很好的協作運行

所謂同步,就是並發進程/線程在一些關鍵點上可能需要互相等待與互通消息,這種相互制約的等待與互通信息稱為進程/線程同步。

舉個生活的同步例子,你肚子餓瞭想要吃飯,你叫媽媽早點做菜,媽媽聽到後就開始做菜,但是在媽媽沒有做完飯之前,你必須阻塞等待,等媽媽做完飯後,自然會通知你,接著你吃飯的事情就可以進行瞭。

註意,同步與互斥是兩種不同的概念:

同步就好比:「操作 A 應在操作 B 之前執行」,「操作 C 必須在操作 A 和操作 B 都完成之後才能執行」等;

互斥就好比:「操作 A 和操作 B 不能在同一時刻執行」;

system V 信號量

信號量用途:主要用於多進程或多線程對公共資源對象的訪問控制。 用來解決多進程(多線程同步的問題),類似於一把鎖,訪問前獲取鎖(獲取不到則等待),訪問後釋放鎖。

多進程/多線程一般是並發執行,如果對公共資源訪問沒有做同步處理,很容易造成數據破壞

信號量其實是一個整型的計數器,主要用於實現進程間的互斥與同步,而不是用於緩存進程間通信的數據。

信號量表示資源的數量,控制信號量的方式有兩種原子操作:

一個是 P 操作,這個操作會把信號量減去 -1,相減後如果信號量 < 0,則表明資源已被占用,進程需阻塞等待;相減後如果信號量 >= 0,則表明還有資源可使用,進程可正常繼續執行。

另一個是 V 操作,這個操作會把信號量加上 1,相加後如果信號量 <= 0,則表明當前有阻塞中的進程,於是會將該進程喚醒運行;相加後如果信號量 > 0,則表明當前沒有阻塞中的進程;

P 操作是用在進入共享資源之前,V 操作是用在離開共享資源之後,這兩個操作是必須成對出現的。

舉個類比,2 個資源的信號量,相當於 2 條火車軌道,PV 操作如下圖過程:

一輛火車進入軌道,相當於信號量的P操作,資源-1,這樣就剩下一條軌道

接著又一輛火車占用另一條軌道,也就是P操作,資源-1

此時交通信號燈變為紅色,因為沒有軌道可用,第三輛火車必須等待

第一輛火車離開軌道,相當於V操作,此時軌道資源為1,交通燈變為綠燈

第三輛火車發現交通信號燈變綠,於是進入火車軌道,軌道資源耗盡為0,於是交通信號燈變為紅燈

在這個火車軌道系統中,軌道是公共資源,每輛火車好比一個線程,交通信號燈起的就是信號量的作用。信號量可以實現鎖的互斥操作,也可以實現進程/線程同步

信號量類型

1)二進制信號量(也叫二值信號量)

此時信號量的初值隻能是0和1。(二進制信號量可以實現互斥鎖操作)

2)一般/計數信號量

此時信號量的初值可以是任意非負數。顯然,其包含二進制信號量。上面舉的火車軌道例子就可以使用計數信號量來實現,一般計數信號量與鎖的區別是它可以允許多個線程/進程(線程的數量由計數信號量初值定義) 同時操作公共資源

一般隻有在開發多進程的時候才可能遇到需要使用信號量的場景,phper 幾乎很少有使用信號量的場景,就算有多進程對公共資源操作,大多也是使用 flock 文件鎖做互斥操作

php模擬多進程操作公共資源

<?php
$file = "num.txt";//定一個空文件
$count =0;
file_put_contents($file,$count);

$pid = pcntl_fork();//fork 一個進程

if($pid == 0){//子進程執行邏輯
    $x = (int)file_get_contents($file);//讀取文件內容
    //i 循環累加
    for($i=0; $i<1000; $i++){
        $x = $x + 1;
    }
    //寫入文件
    file_put_contents($file,$x);
    //子進程退出
    exit(0);
}
//父進程執行邏輯
$x = (int)file_get_contents($file);
for($i=0; $i<1000; $i++){
    $x = $x+1;
}
//累加寫入
file_put_contents($file,$x);

在編寫一個shell 腳本輔助

#!/bin/bash
for a in {1..1000}
do
    (php demo1.php)
    b=`cat num.txt`
    if [ $b != 2000 ]
    then
        echo -e "錯誤$b"
    fi
done

按理來說,變量 $x 最後寫入文件的值應該是2000,但很不幸,並不是如此,我們對上面的腳本執行一下:

運行瞭1000次,發現出現瞭變量$x值結果是 1000 的有8次,雖然發生錯誤的概率比較小,但是在計算機裡是不能容忍的。

為什麼會出現這種情況,我們知道單核cpu系統裡為瞭實現多個程序同時運行的假象,操作系統通常都采用時間片調度,一個進程時間片用完就切換下一個進程運行,加上我們的高級語言不是每一行代碼都是原子性的,比如x = (int)file_get_contents($file) 這行代碼對於我們來說是不可分割是原子性的,但是經過編譯器編譯成匯編碼【機器指令】可能是多條指令實現,這樣就會出現問題,如果指令隻執行到一半進程分配的時間片用完或者被其他進程打斷,都有可能造成數據損壞,導致最後計算結果出現誤差

使用php封裝system v 信號量集函數

<?php
$file = "num.txt";//定一個空文件
$count =0;
$key = ftok("demo1.php","x");
$sem_id = sem_get($key,1);// 第二個參數是個整數,表示設置信號量集,設置為1 把它當做二值信號量來用,用於互斥
file_put_contents($file,$count);
$pid = pcntl_fork();//fork 一個進程
if($pid == 0){//子進程執行邏輯
sem_acquire($sem_id); // P -1 操作 獲取一個信號量 , 如果為0表示資源被占用進程掛起等待信號量釋放
    $x = (int)file_get_contents($file);//讀取文件內容
    //i 循環累加
    for($i=0; $i<1000; $i++){
        $x = $x + 1;
    }
    //寫入文件
    file_put_contents($file,$x);
       sem_release($sem_id); //V +1 操作 釋放信號量
    //子進程退出
    exit(0);
}
//父進程執行邏輯
sem_acquire($sem_id); // P -1 操作  獲取信號量, 如果為0表示資源被占用進程掛起等待信號量釋放
$x = (int)file_get_contents($file);
for($i=0; $i<1000; $i++){
    $x = $x+1;
}
//累加寫入
file_put_contents($file,$x);
sem_release($sem_id); //V +1 操作 釋放信號量

加入信號量後,那就一定保證100%是2000,絕對不會出現其他數值。

到此這篇關於php進程通信之信號量淺析介紹的文章就介紹到這瞭,更多相關php信號量內容請搜索WalkonNet以前的文章或繼續瀏覽下面的相關文章希望大傢以後多多支持WalkonNet!

推薦閱讀: