検索

ホームページ >バックエンド開発 >PHPチュートリアル >PHPマルチプロセスの実践

PHPマルチプロセスの実践

WBOY
WBOYオリジナル
2016-06-20 13:03:021045ブラウズ

PHP マルチプロセスの演習

1. 直接法

pcntl_fork() はプロセスを作成します。親プロセスの戻り値は子プロセスの pid です。-1 はプロセスの作成が失敗したことを示します。 Cとよく似ています。

テストスクリプトtest.php

    // example of multiple processes
    date_default_timezone_set( 'Asia/Chongqing');
    echo "parent start, pid ", getmypid(), "\n" ;
    beep();
    for ($i=0; $i<3; ++$i){
          $pid = pcntl_fork();
           if ($pid == -1){
                 die ("cannot fork" );
          } else if ($pid > 0){
                 echo "parent continue \n";
                 for ($k=0; $k<2; ++$k){
                      beep();
                }
          } else if ($pid == 0){
                 echo "child start, pid ", getmypid(), "\n" ;
                 for ($j=0; $j<5; ++$j){
                      beep();
                }
                 exit ;
          }
    }
    // ***
    function beep(){
           echo getmypid(), "\t" , date( &#39;Y-m-d H:i:s&#39;, time()), "\n" ;
          sleep(1);
    }

コマンドラインから実行
#php -f test.php

出力結果
親の開始、pid 1793
1793 2013-01-14 15:04:17
親は続けます
1793 2013-01-14 15:04:18
子スタート、pid 1794
1794 2013-01-14 15:04:18
1794 2013-01-14 15:04:19
1793 2013-01-14 15:04:19
1794 2013-01-14 15:04:20
親は続けます
1793 2013-01-14 15:04:20
子スタート、pid 1795
1795 2013-01-14 15:04:20
17931794 2013-01-14 15:04:212013-01-14 15:04:21

1795 2013-01-14 15:04:21
1794 2013-01-14 15:04:22
1795 2013-01-14 15:04:22
親は続けます
1793 2013-01-14 15:04:22
子スタート、pid 1796
1796 2013-01-14 15:04:22
1793 2013-01-14 15:04:23
1796 2013-01-14 15:04:23
1795 2013-01-14 15:04:23
1795 2013-01-14 15:04:24
1796 2013-01-14 15:04:24
1796 2013-01-14 15:04:25
1796 2013-01-14 15:04:26

ご覧のとおり、3 つの子プロセスが作成され、親プロセスと並行して実行されます。行の 1 つは、他の行とは若干異なる形式になっています。
17931794 2013-01-14 15:04:212013-01-14 15:04:21
2 つのプロセスが同時に書き込み操作を実行するため、競合が発生します。

2. ブロック方法

ダイレクト方式を使用すると、親プロセスが子プロセスを作成した後、子プロセスの終了を待たずに実行を継続します。ここには問題はないようです。 PHPスクリプトが実行後に自動終了せずにメモリ上に常駐した場合、子プロセスが再利用できない問題が発生します。つまり、ゾンビプロセスです。 pcntl_wai() メソッドを使用してプロセスが終了するのを待ってから、終了したプロセスをリサイクルできます。
テスト スクリプトを次のように変更します: 

$pid = pcntl_fork();
if ($pid == -1){
    ...
} else if ($pid > 0){
     echo "parent continue \n";
     pcntl_wait($status);
     for ($k=0; $k<2; ++$k){
          beep();
    }
} else if ($pid == 0){
     ...
}

コマンドラインから実行
#php -f test.php

出力結果
親の開始、pid 1807
1807 2013-01-14 15:20:05
親は続けます
子スタート、pid 1808
1808 2013-01-14 15:20:06
1808 2013-01-14 15:20:07
1808 2013-01-14 15:20:08
1808 2013-01-14 15:20:09
1808 2013-01-14 15:20:10
1807 2013-01-14 15:20:11
1807 2013-01-14 15:20:12
親は続けます
子スタート、pid 1809
1809 2013-01-14 15:20:13
1809 2013-01-14 15:20:14
1809 2013-01-14 15:20:15
1809 2013-01-14 15:20:16
1809 2013-01-14 15:20:17
1807 2013-01-14 15:20:18
1807 2013-01-14 15:20:19
子スタート、pid 1810
1810 2013-01-14 15:20:20
親は続けます
1810 2013-01-14 15:20:21
1810 2013-01-14 15:20:22
1810 2013-01-14 15:20:23
1810 2013-01-14 15:20:24
1807 2013-01-14 15:20:25
1807 2013-01-14 15:20:26

親プロセスは、pcntl_wait() で自身をブロックし、子プロセスの実行が完了するのを待ってから続行します。

3. ノンブロッキング方式

ブロッキング方式では複数プロセスの並列性が失われます。完成した子プロセスを再利用して並列化する方法もあります。これはブロックしない方法です。
スクリプトを変更します: 

    // example of multiple processes
    date_default_timezone_set( &#39;Asia/Chongqing&#39;);
    declare (ticks = 1);
    pcntl_signal(SIGCHLD, "garbage" );
    echo "parent start, pid ", getmypid(), "\n" ;
    beep();
    for ($i=0; $i<3; ++$i){
          $pid = pcntl_fork();
           if ($pid == -1){
                 die ("cannot fork" );
          } else if ($pid > 0){
                 echo "parent continue \n";
                 for ($k=0; $k<2; ++$k){
                      beep();
                }
          } else if ($pid == 0){
                 echo "child start, pid ", getmypid(), "\n" ;
                 for ($j=0; $j<5; ++$j){
                      beep();
                }
                 exit (0);
          }
    }
    // parent
    while (1){
           // do something else
          sleep(5);
    }
    // ***
    function garbage($signal){
           echo "signel $signal received\n" ;
          
           while (($pid = pcntl_waitpid(-1, $status, WNOHANG))> 0){
                 echo "\t child end pid $pid , status $status\n" ;
          }
    }
    function beep(){
           echo getmypid(), "\t" , date( &#39;Y-m-d H:i:s&#39;, time()), "\n" ;
          sleep(1);
    }

用命令行运行
#php -f test.php &

输出结果
parent start, pid 2066
2066    2013-01-14 16:45:34
parent continue
2066    2013-01-14 16:45:35
child start, pid 2067
2067    2013-01-14 16:45:35
20662067                2013-01-14 16:45:362013-01-14 16:45:36

2067    2013-01-14 16:45:37
parent continue
2066    2013-01-14 16:45:37
child start, pid 2068
2068    2013-01-14 16:45:37
2067    2013-01-14 16:45:38
2068    2013-01-14 16:45:38
2066    2013-01-14 16:45:38
parent continue
2066    2013-01-14 16:45:40
child start, pid 2069
2069    2067    2013-01-14 16:45:40
2013-01-14 16:45:40
2068    2013-01-14 16:45:40
2066    2013-01-14 16:45:41
2069    2013-01-14 16:45:41
2068    2013-01-14 16:45:41
signel 17 received
         child end pid 2067, status 0
2069    2013-01-14 16:45:42
2068    2013-01-14 16:45:42
2069    2013-01-14 16:45:43
signel 17 received
         child end pid 2068, status 0
2069    2013-01-14 16:45:44
signel 17 received
         child end pid 2069, status 0

多个进程又并行运行了，而且运行大约10秒钟之后，用 ps -ef | grep php 查看正在运行的进程，只有一个进程
lqling    2066  1388  0 16:45 pts/1    00:00:00 php -f t5.php
是父进程，子进程被回收了。

4. 子进程退出状态


pcntl_waitpid(-1, $status, WNOHANG) $status 返回子进程的结束状态

5. windows多线程

windows系统不支持pcntl函数，幸好有curl_multi_exec()这个工具，利用内部的多线程，访问多个链接，每个链接可以作为一个任务。

编写脚本 test1.php

    date_default_timezone_set( &#39;Asia/Chongqing&#39;);
    $tasks = array(
         &#39;http://localhost/feedbowl/t2.php?job=task1&#39;,
         &#39;http://localhost/feedbowl/t2.php?job=task2&#39;,
         &#39;http://localhost/feedbowl/t2.php?job=task3&#39;
    );
    $mh = curl_multi_init();
    foreach ($tasks as $i => $task){
         $ch[$i] = curl_init();
         curl_setopt($ch[$i], CURLOPT_URL, $task);
         curl_setopt($ch[$i], CURLOPT_RETURNTRANSFER, 1);
         curl_multi_add_handle($mh, $ch[$i]);
    }
    do {$mrc = curl_multi_exec($mh,$active); } while ($mrc == CURLM_CALL_MULTI_PERFORM);
    while ($active && $mrc == CURLM_OK) {
         if (curl_multi_select($mh) != -1) {
           do {$mrc = curl_multi_exec($mh, $active); } while ($mrc == CURLM_CALL_MULTI_PERFORM);
         }
    }
    // completed, checkout result
    foreach ($tasks as $j => $task){
         if (curl_error($ch[$j])){
              echo "task ${j} [$task ] error " , curl_error($ch[$j]), "\r\n" ;
         } else {
              echo "task ${j} [$task ] get: \r\n" , curl_multi_getcontent($ch[$j]), "\r\n" ;
         }
    }

编写脚本 test2.php

    date_default_timezone_set( &#39;Asia/Chongqing&#39;);
    echo "child start, pid ", getmypid(), "\r\n" ;
    for ($i=0; $i<5; ++$i){
         beep();
    }
    exit (0);
    // ***
    function beep(){
        echo getmypid(), "\t" , date(&#39;Y-m-d H:i:s&#39; , time()), "\r\n";
        sleep(1);
    }

用命令行运行
#php -f test1.php &

输出结果
task 0 [http://localhost/feedbowl/t2.php?job=task1] get:
child start, pid 5804
5804    2013-01-15 20:22:35
5804    2013-01-15 20:22:36
5804    2013-01-15 20:22:37
5804    2013-01-15 20:22:38
5804    2013-01-15 20:22:39

task 1 [http://localhost/feedbowl/t2.php?job=task2] get:
child start, pid 5804
5804    2013-01-15 20:22:35
5804    2013-01-15 20:22:36
5804    2013-01-15 20:22:37
5804    2013-01-15 20:22:38
5804    2013-01-15 20:22:39

task 2 [http://localhost/feedbowl/t2.php?job=task3] get:
child start, pid 5804
5804    2013-01-15 20:22:35
5804    2013-01-15 20:22:36
5804    2013-01-15 20:22:37
5804    2013-01-15 20:22:38
5804    2013-01-15 20:22:39

从打印的时间看到，多个任务几乎是同时运行的。


声明：
この記事の内容はネチズンが自主的に寄稿したものであり、著作権は原著者に帰属します。このサイトは、それに相当する法的責任を負いません。盗作または侵害の疑いのあるコンテンツを見つけた場合は、admin@php.cn までご連絡ください。
前の記事：phpQueryがメモリを大量に消費する場合の対処方法次の記事：phpQueryがメモリを大量に消費する場合の対処方法

関連記事

続きを見る