海运的博客

使用系统提供的flock函数：

<?php
   function ffwrite($filename,$content) {
      $file = fopen("$filename","a");
      while(1) {
         if (flock($file,LOCK_EX))
         {
            fwrite($file,$content);
            flock($file,LOCK_UN);
            fclose($file);
            break;
            } else {
            usleep(1000);
         }
      }
   }
?>

或根据创建文件判断其它进程是否在写操作，性能略差，测试1000次20进程写操作慢3%。

<?php
 function _fwrite($filename, $content) {
     $filename_lock = $filename . '.lock';
     while(1)
     {
         if(file_exists($filename_lock))
            {
             usleep(1000);
             } else {
             touch($filename_lock); 
             $f = fopen($filename, 'a');
             fwrite($f, "$content");
             fclose($f);
             unlink($filename_lock);
             break;
             }       
         }
     if(file_exists($filename_lock))
        {
         unlink($filename_lock);
         }
     }
 ?>

<?php
 function getFileLines($filename, $startLine = 1, $endLine = 50, $method = 'rb'){
     $content = array();
    
     if (version_compare(PHP_VERSION, '5.1.0', '>=')){ // 5.1版本之上使用Splfileobject
         $count = $endLine - $startLine;
         $fp = new SplFileObject($filename, $method);
         $fp -> seek($startLine - 1); // 转到$startLine行,seek方法从0开始计数
         for ($i = 0; $i <= $count; ++$i){
             $content[] = trim(($fp -> current()), "\n"); //current()方法取当前行清除换行保存到数组
             $fp -> next(); //循环下一行
             }
         }else{ // PHP<5.1
         $fp = fopen($filename, $method);
         if (!$fp)
             return 'error:can not read file';
         for ($i = 1; $i < $startLine; ++$i){ //定位到$startLine行
             fgets($fp);
            }
        
        for ($i; $i <= $endLine; ++$i){
             $content[] = fgets($fp); //从$startLine行开始循环读取到$endLine行
            }
        fclose($fp);
        }
    return array_filter($content); //返回array_filter(flase,null,0)过滤后的数组
    }
?>

示例：

<?php
$filename = 'file.txt';
$start = 1;
$end = 10;
$count = $end - $start;
while (true){
     $data = getFileLines($filename, $start, $end);
     // var_dump($data);
    $rev = ver($data);
     if($data[9] == ''){
         die("End");
         sleep(10);
        }
    $start = $start + 10;
    $end = $end + 10;
    }
?>

<?php
   $start = microtime ( true ); 
   sleep(2);
   $end = microtime ( true ); 
   echo "脚本执行时间".($end - $start)."\n";  
?>

<?php
function convert($size)
{
  $unit=array('b','kb','mb','gb','tb','pb');
  return @round($size/pow(1024,($i=floor(log($size,1024)))),2).$unit[$i];
}
$childs = array();

for($i = 0; $i < 10; $i++) {
  $pid = pcntl_fork();
  if($pid == -1)
    die('Could not fork');

  if ($pid) { //主进程执行
    echo "parent \n";
    $childs[] = $pid;
  } else { //子进程执行
    for($i =1;$i<10;$i++)
    {
      $pid = posix_getpid();
      echo '当前进程'.$pid.PHP_EOL;
      echo '当前循环'.$i.PHP_EOL;
      echo '占用内存'.convert(memory_get_usage()) . PHP_EOL;
      sleep(1);
    }
    exit();
  }
}

while(count($childs) > 0) {
  foreach($childs as $key => $pid) {
    $res = pcntl_waitpid($pid, $status, WNOHANG);

    if($res == -1 || $res > 0)
      unset($childs[$key]);
  }
  sleep(1);
}

或：

<?php
   function convert($size)
   {
      $unit=array('b','kb','mb','gb','tb','pb');
      return @round($size/pow(1024,($i=floor(log($size,1024)))),2).$unit[$i];
   }
   //最大的子进程数量
   $maxChildPro = 8;
   //当前的子进程数量
   $curChildPro = 0;

   //当子进程退出时，会触发该函数
   function sig_handler($sig)
   {
      global $curChildPro;
      switch($sig)
      { 
         case SIGCHLD:  
         //当前进程数减一，同时控制段会启动一新进程
         $curChildPro--;
         break;
      }
   }

   //配合pcntl_signal使用，简单的说，是为了让系统产生时间云，让信号捕捉函数能够捕捉到信号量
   declare(ticks=1);

   //注册子进程退出时调用的函数。SIGCHLD：在一个进程终止或者停止时，将SIGCHLD信号发送给其父进程。
   pcntl_signal(SIGCHLD, "sig_handler");
   //整个任务控制
   for ($i = 1; $i <= 5; $i++) 
   //while(true)
   {
      $curChildPro++;
      $pid = pcntl_fork();
      if ($pid)    //父进程运行代码
      {
         if ($curChildPro >= $maxChildPro)
         {
            pcntl_wait($status);
         } 
      }
      else        //子进程运行代码
      {
         //子进程多次循环使用再退出
         for($i =1;$i<10;$i++)
         {
            echo '当前进程'.$curChildPro.PHP_EOL;
            echo '当前循环'.$i.PHP_EOL;
            echo '占用内存'.convert(memory_get_usage()) . PHP_EOL;
            sleep(1);
         }
         exit; 
      }
   }

   //主进程等待所有子进程完成后再退出
   while ($curChildPro)
   {
      pcntl_wait($status);
      //各信号控制冲突，造成负数循环
      //$curChildPro--;
   }