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 = "";     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");}