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

这篇文章主要介绍了ThinkPHP进程计数类Process用法,以实例形式较为详细的分析了Process类的定义及进程计数的实现技巧,具有一定参考借鉴价值,需要的朋友可以参考下

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

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

Process.class.php文件如下：

1. <?php 
2. /** 
3. * Process  
4. *  
5. * @package  
6. * @version $id$ 
7. * @copyright 2005-2011 SUCOP.COM 
8. * @author Dijia Huang <huangdijia@gmail.com>  
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; 
15. /** 
16. * start  
17. *  
18. * @static 
19. * @access public 
20. * @return void 
21. */ 
22. static public function start(){ 
23. $list = self::__getList(); 
24. $name = self::__getName(); 
25. if(!isset($list[$name])){ 
26. $list[$name] = array('count'=>1, 'lasttime'=>time()); 
27. }else{ 
28. if((time()-$list[$name]['time']) > 600){ 
29. $list[$name]['count'] = 1; 
30. }else{ 
31. $list[$name]['count'] += 1; 
32. } 
33. } 
34. self::__setList($list); 
35. } 
36. /** 
37. * destory  
38. *  
39. * @static 
40. * @access public 
41. * @return void 
42. */ 
43. static public function destory(){ 
44. $list = self::__getList(); 
45. $name = self::__getName(); 
46. if(isset($list[$name])){ 
47. if($list[$name]['count'] <= 1){ 
48. unset($list[$name]); 
49. }else{ 
50. $list[$name]['count'] -= 1; 
51. $list[$name]['lasttime'] = time(); 
52. } 
53. self::__setList($list); 
54. } 
55. } 
56. /** 
57. * getCount  
58. *  
59. * @static 
60. * @access public 
61. * @return void 
62. */ 
63. static public function getCount(){ 
64. $list = self::__getList(); 
65. $name = self::__getName(); 
66. return $list[$name]['count']; 
67. } 
68. /** 
69. * getMaxnum  
70. *  
71. * @static 
72. * @access public 
73. * @return void 
74. */ 
75. static public function getMaxnum(){ 
76. $name = self::__getName(); 
77. return C($name) ? C($name) : self::PROCESS_MAXNUM; 
78. } 
79. /** 
80. * getName  
81. *  
82. * @static 
83. * @access public 
84. * @return void 
85. */ 
86. static public function getName(){ 
87. return self::__getName(); 
88. } 
89. /** 
90. * isOvertop  
91. *  
92. * @static 
93. * @access public 
94. * @return void 
95. */ 
96. static public function isOvertop(){ 
97. return (self::getCount() > self::getMaxnum()); 
98. } 
99. /** 
100. * getLasttime  
101. *  
102. * @static 
103. * @access public 
104. * @return void 
105. */ 
106. static public function getLasttime(){ 
107. $list = self::__getList(); 
108. $name = self::__getName(); 
109. return $list[$name]['lasttime']; 
110. } 
111. /** 
112. * clear  
113. *  
114. * @static 
115. * @access public 
116. * @return void 
117. */ 
118. static public function clear(){ 
119. F(self::PROCESS_KEY, null); 
120. } 
121. /** 
122. * __setList  
123. *  
124. * @param mixed $list  
125. * @static 
126. * @access private 
127. * @return void 
128. */ 
129. static private function __setList($list=null){ 
130. if(!is_array($list) || empty($list)) 
131. F(self::PROCESS_KEY, null); 
132. else 
133. F(self::PROCESS_KEY, $list); 
134. } 
135. /** 
136. * __getList  
137. *  
138. * @static 
139. * @access private 
140. * @return void 
141. */ 
142. static private function __getList(){ 
143. $list = F(self::PROCESS_KEY); 
144. if(!is_array($list)) return array(); 
145. else return $list; 
146. } 
147. /** 
148. * __getName  
149. *  
150. * @static 
151. * @access private 
152. * @return void 
153. */ 
154. static private function __getName(){ 
155. return (defined('GROUP_NAME') ? GROUP_NAME.'_' : '') . MODULE_NAME . '_' . ACTION_NAME; 
156. } 
157. } 
158. ?> 

调用方法：

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. function __destruct(){ 
11. Process :: destory(); 
12. }  
13. public function index(){ 
14. C('Index_index', 3); // 动态更改限制数, 默认为10 
15. if(Process::isOvertop()) echo "超出限制"; 
16. else "未超出限制"; 
17. } 
18. } 
19. ?> 

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