视频1 视频21 视频41 视频61 视频文章1 视频文章21 视频文章41 视频文章61 推荐1 推荐3 推荐5 推荐7 推荐9 推荐11 推荐13 推荐15 推荐17 推荐19 推荐21 推荐23 推荐25 推荐27 推荐29 推荐31 推荐33 推荐35 推荐37 推荐39 推荐41 推荐43 推荐45 推荐47 推荐49 关键词1 关键词101 关键词201 关键词301 关键词401 关键词501 关键词601 关键词701 关键词801 关键词901 关键词1001 关键词1101 关键词1201 关键词1301 关键词1401 关键词1501 关键词1601 关键词1701 关键词1801 关键词1901 视频扩展1 视频扩展6 视频扩展11 视频扩展16 文章1 文章201 文章401 文章601 文章801 文章1001 资讯1 资讯501 资讯1001 资讯1501 标签1 标签501 标签1001 关键词1 关键词501 关键词1001 关键词1501 专题2001
php如何多线程
2020-11-27 14:56:04 责编:小采
文档


PHP开启多线程的方法

php如何安装pthreads的拓展的,我采用的是windows安装,我本机的开发环境是phpstudy。

有几点特别需要注意,在window中此类拓展一定是要在线程安全(ts)的php版本中运行。

安装

1、复制php_pthreads.dll 到目录 bin\php\ext\

2、复制pthreadVC2.dll 到目录 C:\windows\system32 下面。

3、打开php配置文件php.ini,在后面加上extension=php_pthreads.dll。

提示!

Windows系统需要将 pthreadVC2.dll 所在路径加入到 PATH 环境变量中。我的电脑--->鼠标右键--->属性--->高级--->环境变量--->系统变量--->找到名称为Path的--->编辑--->在变量值最后面加上pthreadVC2.dll的完整路径。

测试

测试脚本我复制的是http://zyan.cc/pthreads/这里的实例代码。

这里我贴上我的代码,就是在子线程中我添加了日志记录,判断下他的返回值如何

<?php 
set_time_limit(0);
 class test_thread_run extends Thread 
 { 
 public $url; 
 public $data='init'; 
 
 public function __construct($url) 
 { 
 $this->url = $url; 
 } 
 
 public function run() 
 { 
 if(($url = $this->url)) 
 { 
 $this->data = model_http_curl_get($url); 
 } 
 } 
 } 
 
 function model_thread_result_get($urls_array) 
 { 
 foreach ($urls_array as $key => $value) 
 { 
 $thread_array[$key] = new test_thread_run($value["url"]); 
 $thread_array[$key]->start(); 
 } 
 
 foreach ($thread_array as $thread_array_key => $thread_array_value) 
 { 
 while($thread_array[$thread_array_key]->isRunning()) 
 { 
 usleep(10); 
 } 
 if($thread_array[$thread_array_key]->join()) 
 { 
 $variable_data[$thread_array_key] = $thread_array[$thread_array_key]->data; 
 } 
 } 
 return $variable_data; 
 } 
 
 function model_http_curl_get($url,$userAgent="") 
 { 
 $userAgent = $userAgent ? $userAgent : 'Mozilla/4.0 (compatible; MSIE 7.0; Windows NT 5.2)'; 
 $curl = curl_init(); 
 curl_setopt($curl, CURLOPT_URL, $url); 
 curl_setopt($curl, CURLOPT_RETURNTRANSFER, 1); 
 curl_setopt($curl, CURLOPT_TIMEOUT, 5); 
 curl_setopt($curl, CURLOPT_USERAGENT, $userAgent); 
 $result = curl_exec($curl); 
 if($result=== false){
 $result = curl_error($curl);
 }
 curl_close($curl);
 $pid = Thread::getCurrentThreadId();
 $file='D:\\pid\\'.$pid.'p.txt';
 
 file_put_contents($file,$result);
 return $result; 
 } 
 
 for ($i=0; $i < 100; $i++) 
 { 
 $urls_array[] = array("name" => "baidu", "url" => "http://www.baidu.com/s?wd=".mt_rand(10000,20000)); 
 } 
 
 $t = microtime(true); 
 $result = model_thread_result_get($urls_array);
 
 $e = microtime(true); 
 echo "多线程:".($e-$t)."\n"; 
 //print_r($result);
 $t = microtime(true); 
 foreach ($urls_array as $key => $value) 
 { 
 $result_new[$key] = model_http_curl_get($value["url"]); 
 } 
 $e = microtime(true); 
 echo "For循环:".($e-$t)."\n"; 
 //print_r($result_new);
?>

结果在我的目录下:

里面的文本内容是:

也就是说子线程是正常调度了,但是没有拿到数据。此类情况可能是我的网速的原因,垃圾8M电信。

推荐教程:PHP视频教程

下载本文
显示全文
专题