forked from netkiller/netkiller.github.io
-
Notifications
You must be signed in to change notification settings - Fork 0
Expand file tree
/
Copy pathpthreads.html
More file actions
executable file
·218 lines (184 loc) · 10.6 KB
/
Copy pathpthreads.html
File metadata and controls
executable file
·218 lines (184 loc) · 10.6 KB
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
<?xml version="1.0" encoding="UTF-8" standalone="no"?>
<!DOCTYPE html PUBLIC "-//W3C//DTD XHTML 1.0 Transitional//EN" "http://www.w3.org/TR/xhtml1/DTD/xhtml1-transitional.dtd"><html xmlns="http://www.w3.org/1999/xhtml"><head><meta http-equiv="Content-Type" content="text/html; charset=UTF-8" /><title>3.15. pthreads</title><link rel="stylesheet" type="text/css" href="..//docbook.css" /><meta name="generator" content="DocBook XSL Stylesheets V1.78.1" /><meta name="keywords" content="php, pear, pecl, phar" /><link rel="home" href="../index.html" title="Netkiller PHP 手札" /><link rel="up" href="index.html" title="第 3 章 Function Reference" /><link rel="prev" href="pdo.html" title="3.14. PHP Data Objects (PDO)" /><link rel="next" href="../extension/index.html" title="第 5 章 PECL :: The PHP Extension Community Library" /></head><body><a xmlns="" href="http://www.netkiller.cn/">Home</a> |
<a xmlns="" href="http://netkiller.github.io/">简体中文</a> |
<a xmlns="" href="http://netkiller.sourceforge.net/">繁体中文</a> |
<a xmlns="" href="/journal/index.html">杂文</a> |
<a xmlns="" href="/search.html">Search</a> |
<a xmlns="" href="http://netkiller-github-com.iteye.com/">ITEYE 博客</a> |
<a xmlns="" href="http://my.oschina.net/neochen/">OSChina 博客</a> |
<a xmlns="" href="https://www.facebook.com/bg7nyt">Facebook</a> |
<a xmlns="" href="http://cn.linkedin.com/in/netkiller/">Linkedin</a> |
<a xmlns="" href="mailto:netkiller@msn.com">Email</a><div class="navheader"><table width="100%" summary="Navigation header"><tr><th colspan="3" align="center">3.15. pthreads</th></tr><tr><td width="20%" align="left"><a accesskey="p" href="pdo.html">上一页</a> </td><th width="60%" align="center">第 3 章 Function Reference</th><td width="20%" align="right"> <a accesskey="n" href="../extension/index.html">下一页</a></td></tr></table><hr /></div><table xmlns=""><tr><td><iframe src="http://ghbtns.com/github-btn.html?user=netkiller&repo=netkiller.github.com&type=watch&count=true&size=large" height="30" width="170" frameborder="0" scrolling="0" style="width:170px; height: 30px;" allowTransparency="true"></iframe></td><td><iframe src="http://ghbtns.com/github-btn.html?user=netkiller&repo=netkiller.github.com&type=fork&count=true&size=large" height="30" width="170" frameborder="0" scrolling="0" style="width:170px; height: 30px;" allowTransparency="true"></iframe></td><td><iframe src="http://ghbtns.com/github-btn.html?user=netkiller&type=follow&count=true&size=large" height="30" width="240" frameborder="0" scrolling="0" style="width:240px; height: 30px;" allowTransparency="true"></iframe></td></tr></table><div class="section"><div class="titlepage"><div><div><h2 class="title" style="clear: both"><a id="pthreads"></a>3.15. pthreads</h2></div></div></div><div class="section"><div class="titlepage"><div><div><h3 class="title"><a id="idm45254873250544"></a>3.15.1. Thread</h3></div></div></div><pre class="programlisting">
<?php
class test extends Thread {
public $name = '';
public $runing = false;
public function __construct($name) {
$this->name = $name;
$this->runing = true;
}
public function run() {
$n = 0;
while ($this->runing) {
printf("name: %s %s\n",$this->name, $n);
$n++;
sleep(1);
}
}
}
$pool[] = new test('a');
$pool[] = new test('b');
$pool[] = new test('c');
foreach ($pool as $w) {
$w->start();
}
</pre><p>线程池实现方法</p><pre class="programlisting">
$pool = array();
while($member = $row->fetch(PDO::FETCH_ASSOC))
{
while ( true ){
if(count($pool) < 2000){ //定义线程池数量，小于线程池数量则开启新的线程直到小于2000为止
$pool[$id] = new Update($member);
$pool[$id]->start();
break;
}else{
foreach ( $pool as $name => $worker){
//如果线程已经运行结束，销毁线程，给新的任务使用
if(! $worker->isRunning()){
unset($pool[$name]);
}
}
}
}
}
</pre></div><div class="section"><div class="titlepage"><div><div><h3 class="title"><a id="idm45254873248256"></a>3.15.2. Pool</h3></div></div></div><pre class="screen">
<?php
class ExampleWork extends Stackable {
public function __construct($data) {
$this->local = $data;
}
public function run() {
// print_r($this->local);echo "\r\n";
echo '------------------- '. $this->local . " -----------------\r\n";
sleep(1);
}
}
class ExampleWorker extends Worker {
public function __construct($name) {
$this->name = $name;
$this->data = array();
}
public function run(){
$this->name = sprintf("(%lu)", $this->getThreadId());
}
}
/* Dead simple pthreads pool */
class Pool {
/* to hold worker threads */
public $workers;
/* to hold exit statuses */
public $status;
/* prepare $size workers */
public function __construct($size = 10) {
$this->size = $size;
}
/* submit Stackable to Worker */
public function submit(Stackable $stackable) {
if (count($this->workers)<$this->size) {
$id = count($this->workers);
$this->workers[$id] = new ExampleWorker(sprintf("Worker [%d]", $id));
$this->workers[$id]->start(PTHREADS_INHERIT_NONE);
if ($this->workers[$id]->stack($stackable)) {
return $stackable;
} else trigger_error(sprintf("failed to push Stackable onto %s", $this->workers[$id]->getName()), E_USER_WARNING);
}else{
for ($i=0;$i<count($this->workers);$i++){
if( ! $this->workers[$i]->isWorking()){
$this->workers[$i]->stack($stackable);
return $stackable;
}
}
}
return false;
}
public function status(){
for ($i=0;$i<count($this->workers);$i++){
printf("(%s:%s)\r\n",$i, $this->workers[$i]->isWorking());
}
printf("\r\n");
}
/* Shutdown the pool of threads cleanly, retaining exit status locally */
public function shutdown() {
foreach($this->workers as $worker) {
$this->status[$worker->getThreadId()]=$worker->shutdown();
}
}
}
/* Create a pool of ten threads */
$pool = new Pool(100);
/* Create and submit an array of Stackables */
$work = array();
for ($target = 0; $target < 1000; $target++){
$work[$target]=$pool->submit(new ExampleWork($target));
if($work[$target] == false){
$target--;
sleep(1);
continue;
}
for ($i=0;$i<count($work);$i++){
if($work[$i]->isRunning()){
printf("cell: %s, status: %s\r\n",$i, $work[$i]->isRunning());
}
}
printf("\r\n");
}
$pool->shutdown();
exit();
</pre></div><div class="section"><div class="titlepage"><div><div><h3 class="title"><a id="idm45254873244880"></a>3.15.3. FAQ</h3></div></div></div><div class="section"><div class="titlepage"><div><div><h4 class="title"><a id="idm45254873244496"></a>3.15.3.1. You cannot serialize or unserialize PDO instances</h4></div></div></div><pre class="screen">
PHP Fatal error: Uncaught exception 'PDOException' with message 'You cannot serialize or unserialize PDO instances' in /home/www/threads.php:38
Stack trace:
#0 /home/www/threads.php(38): PDO->__sleep()
#1 [internal function]: SQLWorker->run()
#2 {main}
thrown in /home/www/threads.php on line 38
not ready
</pre><pre class="screen">
<?php
class MyWorker extends Worker{
public static $pdo;
function __construct($conf){
$this->conf = $conf;
}
function run(){
self::$pdo = new PDO(
'mysql:host=localhost;dbname=test');
}
function get_connection(){
return self::$pdo;
}
}
?>
</pre></div></div></div><div xmlns="" id="disqus_thread"></div><script xmlns="" type="text/javascript">
/* * * CONFIGURATION VARIABLES: EDIT BEFORE PASTING INTO YOUR WEBPAGE * * */
//if(document.domain == 'netkiller.github.com'){
var disqus_shortname = 'netkiller'; // required: replace example with your forum shortname
//}else{
//var disqus_shortname = 'neochan';
//}
/* * * DON'T EDIT BELOW THIS LINE * * */
(function() {
var dsq = document.createElement('script'); dsq.type = 'text/javascript'; dsq.async = true;
dsq.src = 'http://' + disqus_shortname + '.disqus.com/embed.js';
(document.getElementsByTagName('head')[0] || document.getElementsByTagName('body')[0]).appendChild(dsq);
})();
</script><noscript xmlns="">Please enable JavaScript to view the <a href="http://disqus.com/?ref_noscript">comments powered by Disqus.</a></noscript><a xmlns="" href="http://disqus.com" class="dsq-brlink">comments powered by <span class="logo-disqus">Disqus</span></a><br xmlns="" /><script xmlns="" type="text/javascript" id="clustrmaps" src="//cdn.clustrmaps.com/map_v2.js?u=r5HG&d=9mi5r_kkDC8uxG8HuY3p4-2qgeeVypAK9vMD-2P6BYM"></script><div class="navfooter"><hr /><table width="100%" summary="Navigation footer"><tr><td width="40%" align="left"><a accesskey="p" href="pdo.html">上一页</a> </td><td width="20%" align="center"><a accesskey="u" href="index.html">上一级</a></td><td width="40%" align="right"> <a accesskey="n" href="../extension/index.html">下一页</a></td></tr><tr><td width="40%" align="left" valign="top">3.14. PHP Data Objects (PDO) </td><td width="20%" align="center"><a accesskey="h" href="../index.html">起始页</a></td><td width="40%" align="right" valign="top"> 第 5 章 PECL :: The PHP Extension Community Library</td></tr></table></div><script xmlns="">
(function(i,s,o,g,r,a,m){i['GoogleAnalyticsObject']=r;i[r]=i[r]||function(){
(i[r].q=i[r].q||[]).push(arguments)},i[r].l=1*new Date();a=s.createElement(o),
m=s.getElementsByTagName(o)[0];a.async=1;a.src=g;m.parentNode.insertBefore(a,m)
})(window,document,'script','//www.google-analytics.com/analytics.js','ga');
ga('create', 'UA-11694057-1', 'auto');
ga('send', 'pageview');
</script><script xmlns="" type="text/javascript">
var _bdhmProtocol = (("https:" == document.location.protocol) ? " https://" : " http://");
document.write(unescape("%3Cscript src='" + _bdhmProtocol + "hm.baidu.com/h.js%3F997cd4a7320a82d72cb74d179118f697' type='text/javascript'%3E%3C/script%3E"));
</script><script xmlns="" type="text/javascript" src="/js/q.js"></script></body></html>