分享PHP进程同步代码实例代码

经常遇到这样一种情况，计划任务定时后台执行某个php程序，有时候也需要手动执行，可能多个人都需要执行这个程序，如果任务持续时间非常长，就很容易造成重复执行，所以就开发了下面的类。
作用：在实际代码运行前检查与当前相同操作的进程是否正在运行，高并发运行是可靠的，运行中的进程中途异常中断不会产生任何影响。
构造方法传递pid文件目录的绝对路径，需要自己保证不同进程对应不同pid文件。

 <?php
/*
  * 同一个PHP进程只运行一次，根据进程名字判断是否为排重进程，只能运行于linux，高并发条件下是并发安全的。
  */
class SyncProcess {
 private $pidFile;
 function __construct($pidFile) {
   $this->pidFile = $pidFile;
  }
 /**
   * 非阻塞方式返回进程是否正在运行
   */
  function check() {
   if (PHP_OS == 'Linux') {
    $pidFile = $this->pidFile;
    if (!empty($pidFile)) {
     $flag = false;
     $pidDir = dirname($pidFile);
     if (is_dir($pidDir)) {
      $flag = true;
     }
     if ($flag) {
      $running = true;
      clearstatcache(true, $this->pidFile);
      if (!file_exists($this->pidFile))
       file_put_contents($this->pidFile, '', LOCK_EX);
      $f = fopen($this->pidFile, 'r+');
      if (flock($f, LOCK_EX ^ LOCK_NB)) {
       $pid = trim(fgets($f));
       if (!$this->is_process_running($pid)) {
        $running = false;
       }
      }
      if (!$running) {
       fseek($f, 0);
       ftruncate($f, 0);
       fwrite($f, getmypid());
      }
      flock($f, LOCK_UN);
      fclose($f);
      return $running;
     } else {
      debug_print("pid file($pidFile) is invalid", E_USER_WARNING);
     }
    } else {
     debug_print("pid file cant't be empty", E_USER_WARNING);
    }
   } else {
    debug_print(__CLASS__ . ' can only run in Linux', E_USER_WARNING);
    return true;
   }
  }
 /**
   * 如果正在运行或者发生未知错误返回true，如果没有运行返回false
   * @param mixed $pid
   */
  private function is_process_running($pid) {
   if (is_numeric($pid) && $pid > 0) {
    $output = array();
    $line = exec("ps -o pid --no-headers -p $pid", $output);
    //返回值有空格
    $line = trim($line);
    if ($line == $pid) {
     return true;
    } else {
     if (empty($output)) {
      return false;
     } else {
      if (php_sapi_name() == 'cli')
       $n = "\n";
      else
       $n = "<br>";
      //到这一步的话应该是出什么问题了
      $output = implode($n, $output);
      debug_print($output, E_USER_WARNING);
      return true;
     }
    }
   }else {
    return false;
   }
  }
}

Demo：

 $sync = new SyncProcess(APP_PATH . '/data/pid'.implode('', $this->getRoute()));
 if ($sync->check()) {
  exit("process is running\n");
 }