《PHP實例:PHP進程通信基礎之信號量與共享內存通信》要點:
本文介紹了PHP實例:PHP進程通信基礎之信號量與共享內存通信,希望對您有用。如果有疑問,可以聯系我們。
PHP應用由于進程之間誰先執行并不確定,這取決于內核的進程調度算法,其中比較復雜.由此有可能多進程在相同的時間內同時訪問共享內存,從而造成不可預料的錯誤.信號量這個名字起的令人莫名其妙,但是看其英文原意,就十分容易理解.
PHP應用semaphore 英[?sem?f?:(r)] vt. 發出信號,打旗語;
PHP應用類似于指揮官的作用.
PHP應用下面我們看下一個偽代碼信號量的使用.
PHP應用1、創建信號量唯一標識符
PHP應用$ftok = ftok(__FILE__, 'a');
PHP應用2、創建信號量資源ID
PHP應用$sem_resouce_id = sem_get($ftok);
PHP應用3、接受信號量
PHP應用sem_acqure($sem_resource_id);
PHP應用4、釋放信號量
PHP應用sem_release($sem_resource_id);
PHP應用5、銷毀信號量
PHP應用sem_remove($sem_resource_id);
PHP應用舉個不文雅的例子,使我們容易理解這個信號量在生活中的用法.理解之后可以套用到我們編程領域.
一家公司只有一個衛生間.那么當有人上廁所的時候,都要獲取一把鎖(信號量),表示衛生間正在使用.代碼如下:
PHP應用sem_acqure($sem_resource_id);
PHP應用那么員工上完廁所之后,就需要將鎖打開,釋放鎖(信號量),表示現在可以允許別人使用.代碼如下:
PHP應用sem_release($sem_resource_id);
PHP應用通過一個簡單的鎖,我們就能夠知道當前的廁所(共享內存)是否可以使用.這個例子不雅觀,但說明了問題.這篇博客也是有味道的博客,真是不容易....以下是示例代碼:
PHP應用
<?php
//創建共享內存區域
$shm_key = ftok(__FILE__, 'a');
$shm_id = shm_attach($shm_key, 1024, 0755);
//var_dump($shm_id);die(); resource(4) of type (sysvshm)
const SHARE_KEY = 1;
$child_list = [];
//加入信號量
$sem_id = ftok(__FILE__, 'b');
$signal = sem_get($sem_id);
//$signal resource(5) of type (sysvsem)
for ($i = 0; $i < 3; $i++) {
$pid = pcntl_fork();
if ($pid == -1) {
exit("Fork fail!".PHP_EOL);
} elseif ($pid == 0) {
//獲取信號量
sem_acquire($signal);
if (shm_has_var($shm_id,SHARE_KEY)) {
$count = shm_get_var($shm_id, SHARE_KEY);
$count++;
//模擬業務處理
$sec = rand(1, 3);
sleep($sec);
shm_put_var($shm_id, SHARE_KEY, $count);
} else {
$count = 0;
$sec = rand(1, 3);
sleep($sec);
shm_put_var($shm_id, SHARE_KEY, $count);
}
echo "child process: ".getmypid()." is writing! now count is: $count ".PHP_EOL;
//釋放信號量
sem_release($signal);
exit("child process".getmypid()."end".PHP_EOL);
} else {
$child_list[] = $pid;
}
}
while (count($child_list) > 0) {
foreach ($child_list as $key => $pid) {
$status = pcntl_waitpid($pid, $status);
if ($status > 0 || $status == -1) {
unset($child_list[$key]);
}
}
sleep(1);
}
$count = shm_get_var($shm_id, SHARE_KEY);
echo " $count ".PHP_EOL;
//銷毀信號量
sem_remove($signal);
shm_remove($shm_id);
shm_detach($shm_id);