首页 手机软件 手机游戏 单机游戏 资讯文章 专题下载 游戏合集 文章合集 php下载 php教程 电脑软件
+ -
当前位置：首页 → 问答吧 → 进程计数类Process.class.php

进程计数类Process.class.php

时间：2011-07-13

来源：互联网



项目中有一个需求：由于某一后台任务比较占带宽，所以要限制进程数。花了点时间，写了类，目前版本功能比较简单，源码：
  1. <?php
  2. class Process
  3. {
  4.     const PROCESS_KEY = '~Process';
  5.     const PROCESS_MAXNUM = 10;

  7.     static public function start(){
  8.         $list = self::__getList();
  9.         $name = self::__getName();
  10.         if(!isset($list[$name])){
  11.             $list[$name] = array('count'=>1, 'lasttime'=>time());
  12.         }else{
  13.             $list[$name]['count'] += 1;
  14.         }
  15.         self::__setList($list);
  16.     }

  18.     static public function destory(){
  19.         $list = self::__getList();
  20.         $name = self::__getName();
  21.         if(isset($list[$name])){
  22.             if($list[$name]['count'] <= 1) unset($list[$name]);
  23.             else $list[$name]['count'] -= 1;
  24.             self::__setList($list);
  25.         }
  26.     }

  28.     static public function getCount(){
  29.         $list = self::__getList();
  30.         $name = self::__getName();
  31.         return $list[$name]['count'];
  32.     }

  34.     static public function getMaxnum(){
  35.         $name = self::__getName();
  36.         return C($name) ? C($name) : self::PROCESS_MAXNUM;
  37.     }

  39.     static public function getName(){
  40.         return self::__getName();
  41.     }

  43.     static public function isOvertop(){
  44.         return (self::getCount() > self::getMaxnum());
  45.     }

  47.     static public function getLasttime(){
  48.         $list = self::__getList();
  49.         $name = self::__getName();
  50.         return $list[$name]['lasttime'];
  51.     }

  53.     static public function clear(){
  54.         F(self::PROCESS_KEY, null);
  55.     }

  57.     static private function __setList($list=null){
  58.         if(!is_array($list) || empty($list))
  59.             F(self::PROCESS_KEY, null);
  60.         else
  61.             F(self::PROCESS_KEY, $list);
  62.     }

  64.     static private function __getList(){
  65.         $list = F(self::PROCESS_KEY);
  66.         if(!is_array($list)) return array();
  67.         else return $list;
  68.     }

  70.     static private function __getName(){
  71.         return (defined('GROUP_NAME') ? GROUP_NAME.'_' : '') . MODULE_NAME . '_' . ACTION_NAME;
  72.     }
  73. }
  74. ?>
复制代码
调用方法：
  1. <?php
  2. class IndexAction extends Action
  3. {
  4.     // 初始化模块
  5.     public function _initialize(){
  6.         parent::_initialize();
  7.         import('@.Util.Process');
  8.         Process::start();
  9.     }
  10.    
  11.     function __destruct(){
  12.         Process :: destory();
  13.     }
  14.    
  15.     public function index(){
  16.         C('Index_index', 3); // 动态更改限制数, 默认为10
  17.         if(Process::isOvertop()) echo "超出限制";
  18.         else "未超出限制";
  19.     }
  20. }
  21. ?>
复制代码

作者: deeka   发布时间: 2011-07-13

修正了一些问题。
  1. <?php
  2. /**
  3. * Process
  4. *
  5. * @package
  6. * @version $id$
  7. * @copyright 2005-2011 SUCOP.COM
  8. * @author Dijia Huang <[email protected]>
  9. * @license PHP Version 3.0 {@link http://www.php.net/license/3_0.txt}
  10. */
  11. class Process
  12. {
  13.     const PROCESS_KEY = '~Process';
  14.     const PROCESS_MAXNUM = 10;

  16.     /**
  17.      * start
  18.      *
  19.      * @static
  20.      * @access public
  21.      * @return void
  22.      */
  23.     static public function start(){
  24.         $list = self::__getList();
  25.         $name = self::__getName();
  26.         if(!isset($list[$name])){
  27.             $list[$name] = array('count'=>1, 'lasttime'=>time());
  28.         }else{
  29.             if((time()-$list[$name]['time']) > 600){
  30.                 $list[$name]['count'] = 1;
  31.             }else{
  32.                 $list[$name]['count'] += 1;
  33.             }
  34.         }
  35.         self::__setList($list);
  36.     }

  38.     /**
  39.      * destory
  40.      *
  41.      * @static
  42.      * @access public
  43.      * @return void
  44.      */
  45.     static public function destory(){
  46.         $list = self::__getList();
  47.         $name = self::__getName();
  48.         if(isset($list[$name])){
  49.             if($list[$name]['count'] <= 1){
  50.                 unset($list[$name]);
  51.             }else{
  52.                 $list[$name]['count'] -= 1;
  53.                 $list[$name]['lasttime'] = time();
  54.             }
  55.             self::__setList($list);
  56.         }
  57.     }

  59.     /**
  60.      * getCount
  61.      *
  62.      * @static
  63.      * @access public
  64.      * @return void
  65.      */
  66.     static public function getCount(){
  67.         $list = self::__getList();
  68.         $name = self::__getName();
  69.         return $list[$name]['count'];
  70.     }

  72.     /**
  73.      * getMaxnum
  74.      *
  75.      * @static
  76.      * @access public
  77.      * @return void
  78.      */
  79.     static public function getMaxnum(){
  80.         $name = self::__getName();
  81.         return C($name) ? C($name) : self::PROCESS_MAXNUM;
  82.     }

  84.     /**
  85.      * getName
  86.      *
  87.      * @static
  88.      * @access public
  89.      * @return void
  90.      */
  91.     static public function getName(){
  92.         return self::__getName();
  93.     }

  95.     /**
  96.      * isOvertop
  97.      *
  98.      * @static
  99.      * @access public
  100.      * @return void
  101.      */
  102.     static public function isOvertop(){
  103.         return (self::getCount() > self::getMaxnum());
  104.     }

  106.     /**
  107.      * getLasttime
  108.      *
  109.      * @static
  110.      * @access public
  111.      * @return void
  112.      */
  113.     static public function getLasttime(){
  114.         $list = self::__getList();
  115.         $name = self::__getName();
  116.         return $list[$name]['lasttime'];
  117.     }

  119.     /**
  120.      * clear
  121.      *
  122.      * @static
  123.      * @access public
  124.      * @return void
  125.      */
  126.     static public function clear(){
  127.         F(self::PROCESS_KEY, null);
  128.     }

  130.     /**
  131.      * __setList
  132.      *
  133.      * @param mixed $list
  134.      * @static
  135.      * @access private
  136.      * @return void
  137.      */
  138.     static private function __setList($list=null){
  139.         if(!is_array($list) || empty($list))
  140.             F(self::PROCESS_KEY, null);
  141.         else
  142.             F(self::PROCESS_KEY, $list);
  143.     }

  145.     /**
  146.      * __getList
  147.      *
  148.      * @static
  149.      * @access private
  150.      * @return void
  151.      */
  152.     static private function __getList(){
  153.         $list = F(self::PROCESS_KEY);
  154.         if(!is_array($list)) return array();
  155.         else return $list;
  156.     }

  158.     /**
  159.      * __getName
  160.      *
  161.      * @static
  162.      * @access private
  163.      * @return void
  164.      */
  165.     static private function __getName(){
  166.         return (defined('GROUP_NAME') ? GROUP_NAME.'_' : '') . MODULE_NAME . '_' . ACTION_NAME;
  167.     }
  168. }
  169. ?>
复制代码

作者: deeka   发布时间: 2011-07-14

支持分享，有空研究下。

作者: cl360   发布时间: 2011-07-14

相关阅读 更多

热门阅读

热门下载

更多
关于本站 免责申明 联系我们

Copyright 2006-2020 php爱好者(phpfans.net) All Rights Reserved.备案号：湘ICP备2023016114号-2

本站为非盈利性网站，不接受任何广告。本站所有资源均由网友上传，如有侵权，请发邮件至 [email protected] phpfans.net