如何在php中操作多進(jìn)程

這篇文章將為大家詳細(xì)講解有關(guān)如何在php中操作多進(jìn)程，文章內(nèi)容質(zhì)量較高，因此小編分享給大家做個參考，希望大家閱讀完這篇文章后對相關(guān)知識有一定的了解。

php的多進(jìn)程處理依賴于pcntl擴(kuò)展，通過pcntl_fork創(chuàng)建子進(jìn)程來進(jìn)行并行處理。

例1如下：

<?php
$pid = pcntl_fork();

if($pid == -1) {
  //錯誤處理：創(chuàng)建子進(jìn)程失敗時(shí)返回-1.
  die('fork error');
} else if ($pid) {
  //父進(jìn)程會得到子進(jìn)程號，所以這里是父進(jìn)程執(zhí)行的邏輯
  echo "parent \n";
  //等待子進(jìn)程中斷，防止子進(jìn)程成為僵尸進(jìn)程。
  pcntl_wait($status);
} else {
  //子進(jìn)程得到的$pid為0, 所以這里是子進(jìn)程執(zhí)行的邏輯。
  echo "child \n";

  exit;
}

pcntl_fork創(chuàng)建了子進(jìn)程，父進(jìn)程和子進(jìn)程都繼續(xù)向下執(zhí)行，而不同是父進(jìn)程會獲取子進(jìn)程的$pid也就是$pid不為零。而子進(jìn)程會獲取$pid為零。通過if else語句判斷$pid我們就可以在指定位置寫上不同的邏輯代碼。

上述代碼會分別輸出parent和child。那么輸出的parent和child是否會有順序之分？是父進(jìn)程會先執(zhí)行？

例2如下：

<?php
$pid = pcntl_fork();

if($pid == -1) {
  die('fork error');
} else if ($pid) {
  sleep(3);
  echo "parent \n";
  pcntl_wait($status);
} else {
  echo "child \n";

  exit;
}

我們在父進(jìn)程中通過sleep來延緩執(zhí)行，看看效果。

結(jié)果是，很快輸出了child，等待了接近3秒后，才輸出parent。所以父進(jìn)程和子進(jìn)程的執(zhí)行是相對獨(dú)立的，沒有先后之分。

那么問題又來了？pcntl_wait是做什么用的？
會掛起當(dāng)前進(jìn)程，直到子進(jìn)程退出，如果子進(jìn)程在調(diào)用此函數(shù)之前就已退出，此函數(shù)會立刻返回。子進(jìn)程使用的資源將被釋放。

例3如下：

<?php
$pid = pcntl_fork();

if($pid == -1) {
  die('fork error');
} else if ($pid) {
  pcntl_wait ($status);
  echo "parent \n";
} else {
  sleep(3);
  echo "child \n";

  exit;
}

上述代碼，我們可以看到，父進(jìn)程執(zhí)行pcntl_wait時(shí)就已經(jīng)掛起，直到等待3秒后輸出child，子進(jìn)程退出后。父進(jìn)程繼續(xù)執(zhí)行，輸出parent。

例4如下：

<?php
define('FORK_NUMS', 3);

$pids = array();

for($i = 0; $i < FORK_NUMS; ++$i) {
  $pids[$i] = pcntl_fork();
  if($pids[$i] == -1) {
    die('fork error');
  } else if ($pids[$i]) {
    pcntl_waitpid($pids[$i], $status);
    echo "pernet \n";
  } else {
    sleep(3);
    echo "child id:" . getmypid() . " \n";
    exit;
  }
}

上述代碼，我們創(chuàng)建3個子進(jìn)程，父進(jìn)程分別掛起等待子進(jìn)程結(jié)束后，輸出parent。

輸出結(jié)果如下：

child id:19090
pernet
child id:19091
pernet
child id:19092
pernet

例5如下：

<?php
define('FORK_NUMS', 3);

$pids = array();

for($i = 0; $i < FORK_NUMS; ++$i) {
  $pids[$i] = pcntl_fork();
  if($pids[$i] == -1) {
    die('fork error');
  } else if ($pids[$i]) {

  } else {
    sleep(3);
    echo "child id:" . getmypid() . " \n";
    exit;
  }
}

foreach($pids as $k => $v) {
  if($v) {
    pcntl_waitpid($v, $status);
    echo "parent \n";
  }
}

輸出結(jié)果如下：

child id:19118
child id:19119
child id:19120
parent
parent
parent

為什么上述代碼跟例4的輸出結(jié)果不一樣？

我們可以看到例5的pcntl_waitpid函數(shù)放在了foreach中，foreach代碼是在主進(jìn)程中，也就是父進(jìn)程的代碼中。當(dāng)執(zhí)行foreach時(shí)，可能子進(jìn)程已經(jīng)全部執(zhí)行完畢并退出。pcntl_waitpid會立刻返回，連續(xù)輸出三個parent。

(*在子進(jìn)程中，需通過exit來退出，不然會產(chǎn)生遞歸多進(jìn)程，父進(jìn)程中不需要exit，不然會中斷多進(jìn)程。)

例6如下：

<?php
define('FORK_NUMS', 3);

$pids = array();

$fp = fopen('./test.log', 'wb');
$num = 1;

for($i = 0; $i < FORK_NUMS; ++$i) {
  $pids[$i] = pcntl_fork();
  if($pids[$i] == -1) {
    die('fork error');
  } else if ($pids[$i]) {


  } else {
    for($i = 0; $i < 5; ++$i) {

      flock($fp, LOCK_EX);
      fwrite($fp, getmypid() . ' : ' . date('Y-m-d H:i:s') . " : {$num} \r\n");

      flock($fp, LOCK_UN);
      echo getmypid(), ": success \r\n";
      ++$num;
    }
    exit;
  }
}

foreach($pids as $k => $v) {
  if($v) {
    pcntl_waitpid($v, $status);
  }
}

fclose($fp);

代碼如上：我們創(chuàng)建三個子進(jìn)程，來同時(shí)向test.log文件寫入內(nèi)容，test.log內(nèi)容如下：

19507 : 2016-03-16 20:40:52 : 1
19507 : 2016-03-16 20:40:52 : 2
19507 : 2016-03-16 20:40:52 : 3
19507 : 2016-03-16 20:40:52 : 4
19507 : 2016-03-16 20:40:52 : 5
19509 : 2016-03-16 20:40:52 : 1
19509 : 2016-03-16 20:40:52 : 2
19509 : 2016-03-16 20:40:52 : 3
19509 : 2016-03-16 20:40:52 : 4
19509 : 2016-03-16 20:40:52 : 5
19508 : 2016-03-16 20:40:52 : 1
19508 : 2016-03-16 20:40:52 : 2
19508 : 2016-03-16 20:40:52 : 3
19508 : 2016-03-16 20:40:52 : 4
19508 : 2016-03-16 20:40:52 : 5

我們可以看到三個子進(jìn)程的pid，它們分別執(zhí)行了5次，時(shí)間幾乎是在同時(shí)。但是$num的值并沒像我們期望的那樣從1－15進(jìn)行遞增。子進(jìn)程中的變量是各自獨(dú)立的，互不影響。子進(jìn)程會自動復(fù)制父進(jìn)程空間里的變量。

如何在進(jìn)程中共享數(shù)據(jù)？

我們通過php的共享內(nèi)存函數(shù)shmop來實(shí)現(xiàn)。

<?php
define('FORK_NUMS', 3);

$pids = array();

$fp = fopen('./test.log', 'wb');
$num = 1;
//共享內(nèi)存段的key
$shmKey = 123;
//創(chuàng)建共享內(nèi)存段
$shmId = shmop_open($shmKey, 'c', 0777, 64);
//寫入數(shù)據(jù)到共享內(nèi)存段
shmop_write($shmId, $num, 0);

for($i = 0; $i < FORK_NUMS; ++$i) {
  $pids[$i] = pcntl_fork();
  if($pids[$i] == -1) {
    die('fork error');
  } else if ($pids[$i]) {

    //阻塞，等待子進(jìn)程退出

    //注意這里，如果是非阻塞的話，$num的計(jì)數(shù)會出現(xiàn)問題。
    pcntl_waitpid($pids[$i], $status);
  } else {
    //讀取共享內(nèi)存段中的數(shù)據(jù)
    $num = shmop_read($shmId, 0, 64);
    for($i = 0; $i < 5; ++$i) {
      fwrite($fp, getmypid() . ' : ' . date('Y-m-d H:i:s') . " : {$num} \r\n");
      echo getmypid(), ": success \r\n";
      //遞增$num
      $num = intval($num) + 1;
    }

    //寫入到共享內(nèi)存段中

    shmop_write($shmId, $num, 0);
    exit;
  }
}

//shmop_delete不會實(shí)際刪除該內(nèi)存段，它將該內(nèi)存段標(biāo)記為刪除。
shmop_delete($shmId);
shmop_close($shmId);
fclose($fp);

上述代碼的運(yùn)行結(jié)果如下：

19923 : 2016-03-17 00:05:18 : 1
19923 : 2016-03-17 00:05:18 : 2
19923 : 2016-03-17 00:05:18 : 3
19923 : 2016-03-17 00:05:18 : 4
19923 : 2016-03-17 00:05:18 : 5
19924 : 2016-03-17 00:05:18 : 6
19924 : 2016-03-17 00:05:18 : 7
19924 : 2016-03-17 00:05:18 : 8
19924 : 2016-03-17 00:05:18 : 9
19924 : 2016-03-17 00:05:18 : 10
19925 : 2016-03-17 00:05:18 : 11
19925 : 2016-03-17 00:05:18 : 12
19925 : 2016-03-17 00:05:18 : 13
19925 : 2016-03-17 00:05:18 : 14
19925 : 2016-03-17 00:05:18 : 15

關(guān)于如何在php中操作多進(jìn)程就分享到這里了，希望以上內(nèi)容可以對大家有一定的幫助，可以學(xué)到更多知識。如果覺得文章不錯，可以把它分享出去讓更多的人看到。