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（发邮件时，请将#更换为@）进行举报，并提供相关证据，一经查实，本站将立刻删除涉嫌侵权内容。