pthreads - 求助，php使用Pthread进行多进程的问题？

php中文网

发布： 2016-06-06 20:19:04

原创

1719人浏览过

以下代码运行没有问题，感觉$urls数组有多少数据，就生产多少进程，如果有几万个数据，是不是会有几万个进程？

如果要设置成只有10个进程来处理$urls数组，应该怎么做？

<?php
    header("Content-Type: text/html;charset=utf-8");

    class DuoXianCheng extends Thread {
      public function __construct($arg){
        $this->arg = $arg;
      }
     
      public function run(){
        if($this->arg){
          // echo $this->result = $this->arg;
            $this->result = model_http_curl_get($this->arg);
        }
      }
    }

    $thread = new DuoXianCheng("World");
    if($thread->start()){
        $thread->join();
    }
      

    function model_http_curl_get($url) {
          $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, 'Mozilla/4.0 (compatible; MSIE 7.0; Windows NT 5.2)');  
          $result = curl_exec($curl);  
          curl_close($curl);  
          return $result;  
    }

    for ($i = 0; $i < 10; $i++) {
        $urls[] = 'http://www.baidu.com/s?wd='. rand(10000, 20000);
    }

/* 多线程速度测试 */
    $t = microtime(true);
    foreach ($urls as $key=>$url) {
        $workers[$key] = new \DuoXianCheng($url);
        $workers[$key]->start();
    }
    
    foreach ($workers as $key=>$worker) {
        while($workers[$key]->isRunning()) {
            usleep(100);  
        }
        if ($workers[$key]->join()) {
            var_dump($workers[$key]->result);
        }
    }
    $e = microtime(true);
    echo "多线程耗时：".($e-$t)."秒<br>";  
     
     
    /* 单线程速度测试 */
    $t = microtime(true);
    foreach ($urls as $key=>$url) {
        var_dump(model_http_curl_get($url));
    }
    $e = microtime(true);
    echo "For循环耗时：".($e-$t)."秒<br>";  



?>

登录后复制

回复内容：

以下代码运行没有问题，感觉$urls数组有多少数据，就生产多少进程，如果有几万个数据，是不是会有几万个进程？

如果要设置成只有10个进程来处理$urls数组，应该怎么做？

<?php
    header("Content-Type: text/html;charset=utf-8");

    class DuoXianCheng extends Thread {
      public function __construct($arg){
        $this->arg = $arg;
      }
     
      public function run(){
        if($this->arg){
          // echo $this->result = $this->arg;
            $this->result = model_http_curl_get($this->arg);
        }
      }
    }

    $thread = new DuoXianCheng("World");
    if($thread->start()){
        $thread->join();
    }
      

    function model_http_curl_get($url) {
          $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, 'Mozilla/4.0 (compatible; MSIE 7.0; Windows NT 5.2)');  
          $result = curl_exec($curl);  
          curl_close($curl);  
          return $result;  
    }

    for ($i = 0; $i < 10; $i++) {
        $urls[] = 'http://www.baidu.com/s?wd='. rand(10000, 20000);
    }

/* 多线程速度测试 */
    $t = microtime(true);
    foreach ($urls as $key=>$url) {
        $workers[$key] = new \DuoXianCheng($url);
        $workers[$key]->start();
    }
    
    foreach ($workers as $key=>$worker) {
        while($workers[$key]->isRunning()) {
            usleep(100);  
        }
        if ($workers[$key]->join()) {
            var_dump($workers[$key]->result);
        }
    }
    $e = microtime(true);
    echo "多线程耗时：".($e-$t)."秒<br>";  
     
     
    /* 单线程速度测试 */
    $t = microtime(true);
    foreach ($urls as $key=>$url) {
        var_dump(model_http_curl_get($url));
    }
    $e = microtime(true);
    echo "For循环耗时：".($e-$t)."秒<br>";  



?>

登录后复制

curl_init()不开新进程，但客户机的file descriptor是有限的，内存也是有限的，意味着能new的Thread不是无限的。你要达到pthread要达到的目的，不妨看看http://php.net/manual/en/function.curl-multi-init.php，它允许你异步的处理多个curl_init()返回。

TGroupon团购系统

TGroupon团购系统是以php+MySQL进行开发的团购网站系统，首页能同时显示多个正在进行中的团购商品,将团购中的商品最大限度的展示在用户面前,对提升网站整体销售量有着很大的帮助。安装说明:1:环境：windows/LINUX/UNIX/apache,mysql,php2:所用语言: php,javascript,xml,html3:将程序放置空间或者服务器上，要求uploadfiles目录