php多线程功能是php5.3才真正的支持了,下面我就尝试了pthreads功能的一个测试同时也发测试时发现了一些bug了,具体bug原因还无法解决看其它朋友有经验吗.

近日用PHP处理约7k条网络数据,现有网络情况下,耗时通常一秒一条,跑完整个程序大约近两个小时.

由于跑一次数据的时间太长，因此计划通过多个线程实现并行处理，我们可以通过pthreads扩展来实现真正的多线程，而不是常见的fsockopen来“模拟”。pthreads的官网介绍在这里：http://pthreads.org/

需要注意的是,如果尝试用数组在线程间交换数据,你会失望的,因为php的数组本身不是线程安全的,正确的做法是继承Stackable类,一个简单的demo如下所示:

1. <?php 
2. class storage extends Stackable { 
3. public function run(){} 
4. } 
5.  
6. class my extends Thread { 
7. public function __construct($storage) { 
8. $this->storage = $storage; 
9. } 
10.  
11. public function run(){ 
12. $i = 0;//www.phpfensi.com 
13. while(++$i < 10) { 
14. $this->storage[]=rand(0,1000); 
15. } 
16.  
17. $this->synchronized(function($thread){ 
18. $thread->notify(); 
19. }, $this); 
20. } 
21. } 
22.  
23. $storage = new storage(); 
24. $my = new my($storage); 
25. $my->start(); 
26.  
27. $my->synchronized(function($thread){ 
28. $thread->wait(); 
29. }, $my); 
30.  
31. var_dump($storage); 
32. ?> 

上例如果$storage是array,那么dump出来的将是null,启用多线程后,跑一次数据的时间可以压缩到1000秒内,不到二十分钟,已经在我的接受范围内了.

最后发现一个自动加载BUG

线程的run方法可以继承主线程的常量,函数定义,ini_set()和自动加载不能继承,具体什么能继承什么不能继承没找到相关文档,只能自己摸索.

继承过来的函数中只能进行一些基本操作,如果试图new一个对象(比如PDO)然后返回这个对象就会导致进程意外终止,就目前来说基本不能用于生产环境.

Tags: PHP多线程 pthreads 自动加载BUG

分享到：