• 企业400电话
  • 微网小程序
  • AI电话机器人
  • 电商代运营
  • 全 部 栏 目

    企业400电话 网络优化推广 AI电话机器人 呼叫中心 网站建设 商标✡知产 微网小程序 电商运营 彩铃•短信 增值拓展业务
    PHP pthreads v3下worker和pool的使用方法示例

    本文实例讲述了PHP pthreads v3下worker和pool的使用方法。分享给大家供大家参考,具体如下:

    有些人会想,明明用thread已经可以很好的工作了,为什么还要搞个worker和pool?

    之所以要用到worker和pool还是因为效率,因为系统创建一个新线程代价是比较昂贵,每个创建的线程会复制当前执行的整个上下文。

    尽可能的重用线程可以让我们的程序更高效。

    一个简单的worker例子:

    ?php
    //创建自定义work类,给work取个名字,方便查看
    class Work extends Worker
    {
      private $name;
    
      public function __construct($name)
      {
        $this->name = $name;
      }
    
      public function getName()
      {
        return $this->name;
      }
    }
    
    class Task extends Thread
    {
      private $num;
    
      public function __construct($num)
      {
        $this->num = $num;
      }
    
      public function run()
      {
        //计算累加和
        $total = 0;
        for ($i = 0; $i  $this->num; $i++) {
          $total += $i;
        }
        echo "work : {$this->worker->getName()} task : {$total} \n";
        sleep(1);
      }
    }
    
    //创建一个worker线程
    $work = new Work('a');
    
    $work->start();
    
    for ($i = 1; $i = 10; $i++) {
      //将Task对象压栈到worker线程中
      //这个时候Task对象就可以使用worker线程上下文(变量,函数等)
      $work->stack(new Task($i));
    }
    
    //循环的清理任务,会阻塞主线程,直到栈中任务都执行完毕
    while ($work->collect()) ;
    
    //关闭worker
    $work->shutdown();

    上面代码在运行的时候,计算结果会每隔一秒出来一条,也就是10个task对象是运行在1个worker线程上的。

    如果10个task对象是分别在独立空间运行的,sleep()函数就不会起作用,他们各自sleep并不会影响其他线程。

    把上面的代码修改一下:

    ?php
    //创建自定义work类,给work取个名字,方便查看
    class Work extends Worker
    {
      private $name;
    
      public function __construct($name)
      {
        $this->name = $name;
      }
    
      public function getName()
      {
        return $this->name;
      }
    }
    
    class Task extends Thread
    {
      private $num;
    
      public function __construct($num)
      {
        $this->num = $num;
      }
    
      public function run()
      {
        //计算累加和
        $total = 0;
        for ($i = 0; $i  $this->num; $i++) {
          $total += $i;
        }
        echo "work : {$this->worker->getName()} task : {$total} \n";
        sleep(1);
      }
    }
    
    //创建二个worker线程
    $work1 = new Work('a');
    $work2 = new Work('b');
    
    $work1->start();
    $work2->start();
    
    for ($i = 1; $i = 10; $i++) {
      if ($i = 5) {
        $work1->stack(new Task($i));
      } else {
        $work2->stack(new Task($i));
      }
    }
    
    //循环的清理任务,会阻塞主线程,直到栈中任务都执行完毕
    while ($work1->collect() || $work2->collect()) ;
    
    //关闭worker
    $work1->shutdown();
    $work2->shutdown();
    

    这里我们创建2个worker线程,让10个task对象分别压栈到2个worker中。

    这时可以看到,计算结果是一对一对的出来,说明10个task对象跑在了2个worker线程上。

    至于需要创建多少个worker线程,和多少个task对象,就看自已的需求了。

    worker还有一个好处就是可以重用worker中的对象和方法。我们可以在worker中创建一个连接数据库对象,方便各task调用。

    ?php
    class DB extends Worker
    {
      //注意这里设置为静态成员,pdo连接本身是不能在上下文中共享的
      //声明为静态成员,让每个worker有自已的pdo连接
      private static $db = null;
      public $msg = 'i from db';
    
      public function run()
      {
        self::$db = new PDO('mysql:host=192.168.33.226;port=3306;dbname=test;charset=utf8', 'root', '');
      }
    
      public function getDb()
      {
        return self::$db;
      }
    }
    
    class Task extends Thread
    {
      private $id;
      //注意,这里不要给成员设置默认值,$result成员是线程对象是不可变的,不能被改写
      private $result;
    
      public function __construct($id)
      {
        $this->id = $id;
      }
    
      public function run()
      {
        //获取worker中的数据库连接
        $db = $this->worker->getDb();
        $ret = $db->query("select * from tb_user where id = {$this->id}");
        $this->result = $ret->fetch(PDO::FETCH_ASSOC);
        //访问worker中的成员变量msg
        echo "data : {$this->result['id']} {$this->result['name']} \t worker data : {$this->worker->msg} \n";
      }
    }
    
    //创建一个worker线程
    $work = new DB();
    
    $work->start();
    
    for ($i = 1; $i = 5; $i++) {
      $work->stack(new Task($i));
    }
    
    //循环的清理任务,会阻塞主线程,直到栈中任务都执行完毕
    while ($work->collect()) ;
    
    //关闭worker
    $work->shutdown();
    

    tb_user表大家可以随意创建,我这里为了演示只创建了id和name字段

    运行结果如下:

     

    如果说worker是对线程的重用,那么pool就是对worker更高的抽象了,可以同时管理多个worker。

    ?php
    //之所以要创建一个Id线程类,主要是为了给work取个不同的ID,方便查看,哪些task线程属于哪个work中
    class Id extends Thread
    {
      private $id;
    
      public function getId()
      {
        //防止出现id混乱,这里使用同步操作
        $this->synchronized(function () {
          ++$this->id;
        });
        return $this->id;
      }
    }
    
    class Work extends Worker
    {
      private $id;
    
      public function __construct(Id $obj)
      {
        $this->id = $obj->getId();
      }
    
      public function getId()
      {
        return $this->id;
      }
    }
    
    class Task extends Thread
    {
      private $num = 0;
    
      public function __construct($num)
      {
        $this->num = $num;
      }
    
      //计算累加和
      public function run()
      {
        $total = 0;
        for ($i = 0; $i  $this->num; $i++) {
          $total += $i;
        }
        echo "work id : {$this->worker->getId()} task : {$total} \n";
      }
    }
    
    //创建pool,可容纳3个work对象
    $pool = new Pool(3, 'Work', [new Id()]);
    
    //循环的把20个task线程提交到pool中的work对象上运行
    for ($i = 1; $i = 20; $i++) {
      $pool->submit(new Task($i));
    }
    
    //循环的清理任务,会阻塞主线程,直到任务都执行完毕
    while ($pool->collect()) ;
    
    //关闭pool
    $pool->shutdown();
    

    运行结果如下:

    更多关于PHP相关内容感兴趣的读者可查看本站专题:《PHP进程与线程操作技巧总结》、《PHP网络编程技巧总结》、《PHP基本语法入门教程》、《PHP数组(Array)操作技巧大全》、《php字符串(string)用法总结》、《php+mysql数据库操作入门教程》及《php常见数据库操作技巧汇总》

    希望本文所述对大家PHP程序设计有所帮助。

    您可能感兴趣的文章:
    • PHP pthread拓展使用和注意点
    • PHP pthreads v3下同步处理synchronized用法示例
    • PHP pthreads v3使用中的一些坑和注意点分析
    • php使用pthreads v3多线程实现抓取新浪新闻信息操作示例
    • PHP中使用pthread拓展
    上一篇:PHP pthreads v3下同步处理synchronized用法示例
    下一篇:PHP pthreads v3在centos7平台下的安装与配置操作方法
  • 相关文章
  • 

    © 2016-2020 巨人网络通讯 版权所有

    《增值电信业务经营许可证》 苏ICP备15040257号-8

    PHP pthreads v3下worker和pool的使用方法示例 PHP,pthreads,下,worker,和,pool,