PHP pthreads v3下worker和pool的使用方法示例
本文实例讲述了PHPpthreadsv3下worker和pool的使用方法。分享给大家供大家参考,具体如下:
有些人会想,明明用thread已经可以很好的工作了,为什么还要搞个worker和pool?
之所以要用到worker和pool还是因为效率,因为系统创建一个新线程代价是比较昂贵,每个创建的线程会复制当前执行的整个上下文。
尽可能的重用线程可以让我们的程序更高效。
一个简单的worker例子:
name=$name; } publicfunctiongetName() { return$this->name; } } classTaskextendsThread { private$num; publicfunction__construct($num) { $this->num=$num; } publicfunctionrun() { //计算累加和 $total=0; for($i=0;$i<$this->num;$i++){ $total+=$i; } echo"work:{$this->worker->getName()}task:{$total}\n"; sleep(1); } } //创建一个worker线程 $work=newWork('a'); $work->start(); for($i=1;$i<=10;$i++){ //将Task对象压栈到worker线程中 //这个时候Task对象就可以使用worker线程上下文(变量,函数等) $work->stack(newTask($i)); } //循环的清理任务,会阻塞主线程,直到栈中任务都执行完毕 while($work->collect()); //关闭worker $work->shutdown();
上面代码在运行的时候,计算结果会每隔一秒出来一条,也就是10个task对象是运行在1个worker线程上的。
如果10个task对象是分别在独立空间运行的,sleep()函数就不会起作用,他们各自sleep并不会影响其他线程。
把上面的代码修改一下:
name=$name; } publicfunctiongetName() { return$this->name; } } classTaskextendsThread { private$num; publicfunction__construct($num) { $this->num=$num; } publicfunctionrun() { //计算累加和 $total=0; for($i=0;$i<$this->num;$i++){ $total+=$i; } echo"work:{$this->worker->getName()}task:{$total}\n"; sleep(1); } } //创建二个worker线程 $work1=newWork('a'); $work2=newWork('b'); $work1->start(); $work2->start(); for($i=1;$i<=10;$i++){ if($i<=5){ $work1->stack(newTask($i)); }else{ $work2->stack(newTask($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调用。
id=$id; } publicfunctionrun() { //获取worker中的数据库连接 $db=$this->worker->getDb(); $ret=$db->query("select*fromtb_userwhereid={$this->id}"); $this->result=$ret->fetch(PDO::FETCH_ASSOC); //访问worker中的成员变量msg echo"data:{$this->result['id']}{$this->result['name']}\tworkerdata:{$this->worker->msg}\n"; } } //创建一个worker线程 $work=newDB(); $work->start(); for($i=1;$i<=5;$i++){ $work->stack(newTask($i)); } //循环的清理任务,会阻塞主线程,直到栈中任务都执行完毕 while($work->collect()); //关闭worker $work->shutdown();
tb_user表大家可以随意创建,我这里为了演示只创建了id和name字段
运行结果如下:
如果说worker是对线程的重用,那么pool就是对worker更高的抽象了,可以同时管理多个worker。
synchronized(function(){ ++$this->id; }); return$this->id; } } classWorkextendsWorker { private$id; publicfunction__construct(Id$obj) { $this->id=$obj->getId(); } publicfunctiongetId() { return$this->id; } } classTaskextendsThread { private$num=0; publicfunction__construct($num) { $this->num=$num; } //计算累加和 publicfunctionrun() { $total=0; for($i=0;$i<$this->num;$i++){ $total+=$i; } echo"workid:{$this->worker->getId()}task:{$total}\n"; } } //创建pool,可容纳3个work对象 $pool=newPool(3,'Work',[newId()]); //循环的把20个task线程提交到pool中的work对象上运行 for($i=1;$i<=20;$i++){ $pool->submit(newTask($i)); } //循环的清理任务,会阻塞主线程,直到任务都执行完毕 while($pool->collect()); //关闭pool $pool->shutdown();
运行结果如下:
更多关于PHP相关内容感兴趣的读者可查看本站专题:《PHP进程与线程操作技巧总结》、《PHP网络编程技巧总结》、《PHP基本语法入门教程》、《PHP数组(Array)操作技巧大全》、《php字符串(string)用法总结》、《php+mysql数据库操作入门教程》及《php常见数据库操作技巧汇总》
希望本文所述对大家PHP程序设计有所帮助。
声明:本文内容来源于网络,版权归原作者所有,内容由互联网用户自发贡献自行上传,本网站不拥有所有权,未作人工编辑处理,也不承担相关法律责任。如果您发现有涉嫌版权的内容,欢迎发送邮件至:czq8825#qq.com(发邮件时,请将#更换为@)进行举报,并提供相关证据,一经查实,本站将立刻删除涉嫌侵权内容。