php 实现多线程
下面给出通过 fsockopen() 建立socket连接,然后用 用fputs() 发送消息,来实现的PHP多线程类代码:
$fp=fsockopen($_SERVER['HTTP_HOST'],80,&$errno,&$errstr,5);
if(!$fp){
echo "$errstr ($errno)
\n";
}
fputs($fp,"GET $_SERVER[PHP_SELF]?flag=1\r\n");
fclose($fp);
上面这段代码只是一个线程的操作过程。多进行几个这样的操作就是多线程了。目前所谓PHP的多线程程序都是基于这个方式的。
下面给一个完整的线程类代码。
/**
@title:PHP多线程类(Thread)
@version:1.0
@author:axgle
*/
class thread {
var $count;
function thread($count=1) {
$this->count=$count;
}
function _submit() {
for($i=1;$icount;$i++) $this->_thread();
return true;
}
function _thread() {
$fp=fsockopen($_SERVER['HTTP_HOST'],80,&$errno,&$errstr,5);
if(!$fp){
echo "$errstr ($errno)
\n";
}
fputs($fp,"GET $_SERVER[PHP_SELF]?flag=1\r\n");
fclose($fp);
}
function exec($func) {
isset($_GET['flag'])?call_user_func($func):$this->_submit();
}
}
//应用例子:
$th=new thread(10);//10个线程
$th->exec('demo');//执行行自定义的函数
function demo() {
fopen('data/'.microtime(),'w');
}
?>
http://codechina.spaces.live.com/blog/cns!bca6db10a924c24!575.entry
以上就介绍了php 实现多线程,包括了方面的内容,希望对PHP教程有兴趣的朋友有所帮助。