<?php
/**
 * 是否可以運(yùn)行
 *
 * @param string $ident 標(biāo)識(shí)
 * @param integer $maxNum 最大運(yùn)行數(shù)量
 *
 * @return bool
 */
function canRun($ident, $maxNum)
{
  $cmd = sprintf('ps ax | grep %s | grep -v /bin/sh | grep -v grep | wc -l', $ident);
  $fp = @popen($cmd, 'r');
  $num = (int)trim(@fread($fp, 2096));
  @pclose($fp);
  return $num <= $maxNum;
}

<?php
/**
 * 檢查 pid 是否存活
 *
 * @param string $pid  PID
 * @param string $ident 標(biāo)識(shí)
 *
 * @return bool
 */
function isSurvive($pid, $ident)
{
  // 獲取指定pid的cmdline文件
  $cmdlinePath = sprintf('/proc/%s/cmdline', $pid);
  if (!is_file($cmdlinePath)) {
   return false;
  }
  $cmdline = trim(file_get_contents($cmdlinePath));
  // 檢查標(biāo)識(shí)是否在 cmdline 中
  return strpos($cmdline, $ident) !== false;
}

/**
 * 是否可以運(yùn)行
 *
 * @param string $ident 標(biāo)識(shí)
 * @param integer $maxNum 最大運(yùn)行數(shù)量
 *
 * @return bool
 */
function canRun($ident, $maxNum)
{
  // 假設(shè)已經(jīng)鏈接上
  $redisHandler = getRedis();
  // 定義一個(gè)key
  $key = sprintf('php:job:%s:pid', $ident);
  // 當(dāng)前的PID
  $currentPid = getmypid();
  // 將當(dāng)前的PID寫(xiě)入redis
  $redis->sAdd($key, $currentPid);
  // 獲取redis中的所有pid
  $pids = $redis->sMembers($key);
  // 遍歷pid，檢查是否有效
  foreach ($pids as $index => $pid) {
    if ($currentPid == $pid) {
      continue;
    }
    // 檢查 pid 是否還在運(yùn)行中
    if (isSurvive($pid, $ident)) {
      continue;
    }
    // 若不再運(yùn)行，則直接刪除
    unset($pids[$index]);
    $redis->sRemove($key, $pid);
  }
  return count($pids) <= $maxNum;
}

PID  USER   TIME COMMAND
  1 root   0:09 php-fpm: master process (/usr/local/etc/php-fpm.conf)
  7 root   0:16 php-fpm: pool www
  8 root   0:15 php-fpm: pool www
  9 root   0:14 php-fpm: pool www
  10 root   0:00 sh
 663 root   0:00 sh
 690 root   0:00 {php} Job Demo
 691 root   0:00 ps ax