本文实例讲述了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();
内容版权声明:除非注明,否则皆为本站原创文章。