ThinkPHP进程计数类Process用法实例详解

本文实例讲述了ThinkPHP进程计数类Process用法。分享给大家供大家参考。具体如下：

项目中有一个需求：由于某一后台任务比较占带宽，所以要限制进程数。花了点时间，写了类，目前版本功能比较简单。

Process.class.php文件如下：

    <?php
    /**
     * Process 
     * 
     * @package 
     * @version $id$
     * @copyright 2005-2011 SUCOP.COM
     * @author Dijia Huang <huangdijia@gmail.com> 
     * @license PHP Version 3.0 {@link http://www.php.net/license/3_0.txt}
     */
    class Process
    {
      const PROCESS_KEY = '~Process';
      const PROCESS_MAXNUM = 10;
      /**
       * start 
       * 
       * @static
       * @access public
       * @return void
       */
      static public function start(){
        $list = self::__getList();
        $name = self::__getName();
        if(!isset($list[$name])){
          $list[$name] = array('count'=>1, 'lasttime'=>time());
        }else{
          if((time()-$list[$name]['time']) > 600){
            $list[$name]['count'] = 1;
          }else{
            $list[$name]['count'] += 1;
          }
        }
        self::__setList($list);
      }
      /**
       * destory 
       * 
       * @static
       * @access public
       * @return void
       */
      static public function destory(){
        $list = self::__getList();
        $name = self::__getName();
        if(isset($list[$name])){
          if($list[$name]['count'] <= 1){
            unset($list[$name]);
          }else{
            $list[$name]['count'] -= 1;
            $list[$name]['lasttime'] = time();
          }
          self::__setList($list);
        }
      }
      /**
       * getCount 
       * 
       * @static
       * @access public
       * @return void
       */
      static public function getCount(){
        $list = self::__getList();
        $name = self::__getName();
        return $list[$name]['count'];
      }
      /**
       * getMaxnum 
       * 
       * @static
       * @access public
       * @return void
       */
      static public function getMaxnum(){
        $name = self::__getName();
        return C($name) ? C($name) : self::PROCESS_MAXNUM;
      }
      /**
       * getName 
       * 
       * @static
       * @access public
       * @return void
       */
      static public function getName(){
        return self::__getName();
      }
      /**
       * isOvertop 
       * 
       * @static
       * @access public
       * @return void
       */
      static public function isOvertop(){
        return (self::getCount() > self::getMaxnum());
      }
      /**
       * getLasttime 
       * 
       * @static
       * @access public
       * @return void
       */
      static public function getLasttime(){
        $list = self::__getList();
        $name = self::__getName();
        return $list[$name]['lasttime'];
      }
      /**
       * clear 
       * 
       * @static
       * @access public
       * @return void
       */
      static public function clear(){
        F(self::PROCESS_KEY, null);
      }
      /**
       * __setList 
       * 
       * @param mixed $list 
       * @static
       * @access private
       * @return void
       */
      static private function __setList($list=null){
        if(!is_array($list) || empty($list))
          F(self::PROCESS_KEY, null);
        else
          F(self::PROCESS_KEY, $list);
      }
      /**
       * __getList 
       * 
       * @static
       * @access private
       * @return void
       */
      static private function __getList(){
        $list = F(self::PROCESS_KEY);
        if(!is_array($list)) return array();
        else return $list;
      }
      /**
       * __getName 
       * 
       * @static
       * @access private
       * @return void
       */
      static private function __getName(){
        return (defined('GROUP_NAME') ? GROUP_NAME.'_' : '') . MODULE_NAME . '_' . ACTION_NAME;
      }
    }
    ?>

调用方法：

    <?php
    class IndexAction extends Action 
    {
      // 初始化模块
      public function _initialize(){
        parent::_initialize();
        import('@.Util.Process');
        Process::start();
      }
      function __destruct(){
        Process :: destory();
      } 
      public function index(){
        C('Index_index', 3); // 动态更改限制数, 默认为10
        if(Process::isOvertop()) echo "超出限制";
        else "未超出限制";
      }
    }
    ?>

希望本文所述对大家基于ThinkPHP框架的php程序设计有所帮助。