推荐手册:php完全自学手册
php处理多线程
注意事项
1、php5.3或以上,且为线程安全版本。apache和php使用的编译器必须一致。
2、通过phpinfo()查看thread safety为enabled则为线程安全版。
3、通过phpinfo()查看compiler项可以知道使用的编译器。本人的为:msvc9 (visual c++ 2008)。
本人使用环境
32位windows xp sp3,wampserver2.2d(php5.3.10-vc9 + apache2.2.21-vc9)。
一、下载pthreads扩展
根据本人环境,我下载的是pthreads-2.0.8-5.3-ts-vc9-x86。
2.0.8代表pthreads的版本。
5.3代表php的版本。
ts表示php要线程安全版本的。
vc9表示php要visual c++ 2008编译器编译的。
x86则表示32位的
二、安装pthreads扩展
1、复制php_pthreads.dll 到目录 bin\php\ext\ 下面。(本人路径d:\wamp\bin\php\php5.3.10\ext)
2、复制pthreadvc2.dll 到目录 bin\php\ 下面。(本人路径d:\wamp\bin\php\php5.3.10)
3、复制pthreadvc2.dll 到目录 c:\windows\system32 下面。
4、打开php配置文件php.ini。在后面加上extension=php_pthreads.dll
提示!
windows系统需要将 pthreadvc2.dll 所在路径加入到 path 环境变量中。我的电脑--->鼠标右键--->属性--->高级--->环境变量--->系统变量--->找到名称为path的--->编辑--->在变量值最后面加上pthreadvc2.dll的完整路径。
三、测试pthreads扩展
class asyncoperation extends \thread { public function __construct($arg){ $this->arg = $arg; } public function run(){ if($this->arg){ printf("hello %s\n", $this->arg); } }}$thread = new asyncoperation("world");if($thread->start()) $thread->join();?>
运行以上代码出现 hello world,说明pthreads扩展安装成功!
二 、curl_multi_init()
<?phpecho date("y-m-d h:m:s",time());echo " ";echo floor(microtime()*1000);echo "<br>";$mtime = explode(" ", microtime());$mtime = $mtime[1].($mtime[0] * 1000);$mtime2 = explode(".", $mtime);$mtime = $mtime2[0];echo $mtime;echo "<br>";$urls = array('http://www.webkaka.com','http://www.webkaka.com','http://www.webkaka.com','http://www.webkaka.com','http://www.webkaka.com');print_r(async_get_url($urls)); // [0] => example1, [1] => example2echo "<br>";echo date("y-m-d h:m:s",time());echo " ";echo floor(microtime()*1000);echo "<br>";$mtime_ = explode(" ", microtime());$mtime_ = $mtime_[1].($mtime_[0] * 1000);$mtime2_ = explode(".", $mtime_);$mtime_ = $mtime2_[0];echo $mtime_;echo "<br>";echo $mtime_ - $mtime;function async_get_url($url_array, $wait_usec = 0){if (!is_array($url_array))return false;$wait_usec = intval($wait_usec);$data = array();$handle = array();$running = 0;$mh = curl_multi_init(); // multi curl handler$i = 0;foreach($url_array as $url) {$ch = curl_init();curl_setopt($ch, curlopt_url, $url);curl_setopt($ch, curlopt_returntransfer, 1); // return don't printcurl_setopt($ch, curlopt_timeout, 30);curl_setopt($ch, curlopt_useragent, 'mozilla/4.0 (compatible; msie 5.01; windows nt 5.0)');curl_setopt($ch, curlopt_followlocation, 1); // 302 redirectcurl_setopt($ch, curlopt_maxredirs, 7);curl_multi_add_handle($mh, $ch); // 把 curl resource 放进 multi curl handler 里$handle[$i++] = $ch;}/* 执行 */do {curl_multi_exec($mh, $running);if ($wait_usec > 0) /* 每个 connect 要间隔多久 */usleep($wait_usec); // 250000 = 0.25 sec} while ($running > 0);/* 读取资料 */foreach($handle as $i => $ch) {$content = curl_multi_getcontent($ch);$data[$i] = (curl_errno($ch) == 0) ? $content : false;}/* 移除 handle*/foreach($handle as $ch) {curl_multi_remove_handle($mh, $ch);}curl_multi_close($mh);return $data;}?>
关于curl_multi_init()
一般来说,想到要用curl_multi_init()时,目的是要同时请求多个url,而不是一个一个依次请求,否则就要curl_init()了。不过,在使用curl_multi的时候,你可能遇到cpu消耗过高、网页假死等现象,可以看看如何解决curl_multi导致网页假死的问题。
使用curl_multi的步骤总结如下:
第一步:调用curl_multi_init
第二步:循环调用curl_multi_add_handle
这一步需要注意的是,curl_multi_add_handle的第二个参数是由curl_init而来的子handle。
第三步:持续调用curl_multi_exec
第四步:根据需要循环调用curl_multi_getcontent获取结果
第五步:调用curl_multi_remove_handle,并为每个字handle调用curl_close
第六步:调用curl_multi_close
各函数作用解释:
curl_multi_init()
初始化一个curl批处理句柄资源。
curl_multi_add_handle()
向curl批处理会话中添加单独的curl句柄资源。curl_multi_add_handle()函数有两个参数,第一个参数表示一个curl批处理句柄资源,第二个参数表示一个单独的curl句柄资源。
curl_multi_exec()
解析一个curl批处理句柄,curl_multi_exec()函数有两个参数,第一个参数表示一个批处理句柄资源,第二个参数是一个引用值的参数,表示剩余需要处理的单个的curl句柄资源数量。
curl_multi_remove_handle()
移除curl批处理句柄资源中的某个句柄资源,curl_multi_remove_handle()函数有两个参数,第一个参数表示一个curl批处理句柄资源,第二个参数表示一个单独的curl句柄资源。
curl_multi_close()
关闭一个批处理句柄资源。
curl_multi_getcontent()
在设置了curlopt_returntransfer的情况下,返回获取的输出的文本流。
curl_multi_info_read()
获取当前解析的curl的相关传输信息。
相关文章推荐:
1.php中多线程的实现方法
2.php实现多线程的三种方法
相关视频推荐:
1.独孤九贱(4)_php视频教程
推荐教程:php视频教程
以上就是php如何处理多线程的详细内容。