PHPマルチプロセス処理並列タスク-PHPチュートリアル-php.cn

PHPマルチプロセス処理並列タスク

小云云

リリース： 2023-03-22 14:44:01

オリジナル

2218 人が閲覧しました

この記事では、Linux 環境で PHP を使用して同時タスク処理を行う方法と、パイプを使用してプロセス間のデータ同期を行う方法を例を挙げて説明します。メモとして比較的簡単に書きました。

PHP マルチプロセス

マルチプロセス機能は、pcntl_XXX 一連の関数を通じて使用します。注: pcntl_XXX は php CLI (コマンドライン) 環境でのみ実行できます。Web サーバー環境では、予期しない結果が発生する可能性があるため、注意して使用してください。

PIPE

パイプラインは、略語間の通信データを運ぶために使用されます。理解を容易にするために、パイプをファイルに例えると、プロセス A がパイプ P にデータを書き込み、次にプロセス B がパイプ P からデータを読み取ります。 PHP が提供するパイプライン操作 API は、パイプラインの作成に posix_mkfifo 関数を使用する点を除き、ファイル操作関数と基本的に同じです。もちろん、ファイルを使用してパイプを直接シミュレートすることはできますが、その場合、パイプの機能は使用できなくなります。

ゾンビプロセス

子プロセスが終了すると、親プロセスは待機せず(waitまたはwaitpidを呼び出す)、子プロセスの終了後にすべてのリソースが解放されません(無駄です!)。はゾンビプロセスと呼ばれ、子プロセスの終了時に関連データが保存されます。ゾンビプロセスが多すぎると、多くのシステムリソース (メモリなど) を占有し、マシンのパフォーマンスに影響を与えます。

コード

/** 
 * this is a demo for php fork and pipe usage. fork use 
 * to create child process and pipe is used to sychoroize 
 * the child process and its main process. 
 * @author bourneli 
 * @date: 2012-7-6 
 */  
   
define("PC", 10); // 进程个数  
define("TO", 4); // 超时  
define("TS", 4); // 事件跨度，用于模拟任务延时  
   
if (!function_exists(&#39;pcntl_fork&#39;)) {  
    die("pcntl_fork not existing");  
}  
   
// 创建管道  
$sPipePath = "my_pipe.".posix_getpid();  
if (!posix_mkfifo($sPipePath, 0666)) {  
    die("create pipe {$sPipePath} error");  
}  
   
// 模拟任务并发  
for ($i = 0; $i < PC; ++$i ) {  
    $nPID = pcntl_fork(); // 创建子进程  
    if ($nPID == 0) {  
        // 子进程过程  
        sleep(rand(1,TS)); // 模拟延时  
        $oW = fopen($sPipePath, &#39;w&#39;);  
        fwrite($oW, $i."\n"); // 当前任务处理完比，在管道中写入数据  
        fclose($oW);  
        exit(0); // 执行完后退出  
    }  
}  
   
// 父进程  
$oR = fopen($sPipePath, &#39;r&#39;);  
stream_set_blocking($oR, FALSE); // 将管道设置为非堵塞，用于适应超时机制  
$sData = &#39;&#39;; // 存放管道中的数据  
$nLine = 0;  
$nStart = time();  
while ($nLine < PC && (time() - $nStart) < TO) {  
    $sLine = fread($oR, 1024);  
    if (empty($sLine)) {  
        continue;     
    }     
       
    echo "current line: {$sLine}\n";  
    // 用于分析多少任务处理完毕，通过‘\n’标识  
    foreach(str_split($sLine) as $c) {  
        if ("\n" == $c) {  
            ++$nLine;  
        }  
    }  
    $sData .= $sLine;  
}  
echo "Final line count:$nLine\n";  
fclose($oR);  
unlink($sPipePath); // 删除管道，已经没有作用了  
   
// 等待子进程执行完毕，避免僵尸进程  
$n = 0;  
while ($n < PC) {  
    $nStatus = -1;  
    $nPID = pcntl_wait($nStatus, WNOHANG);  
    if ($nPID > 0) {  
        echo "{$nPID} exit\n";  
        ++$n;  
    }  
}  
   
// 验证结果，主要查看结果中是否每个任务都完成了  
$arr2 = array();  
foreach(explode("\n", $sData) as $i) {// trim all  
    if (is_numeric(trim($i))) {  
        array_push($arr2, $i);    
    }  
}  
$arr2 = array_unique($arr2);  
if ( count($arr2) == PC) {    
    echo &#39;ok&#39;;   
} else {  
    echo  "error count " . count($arr2) . "\n";  
    var_dump($arr2);  
}

ログイン後にコピー