本文实例讲述了PHP pthreads v3下worker和pool的使用方法。分享给大家供大家参考,具体如下:
有些人会想,明明用thread已经可以很好的工作了,为什么还要搞个worker和pool?
之所以要用到worker和pool还是因为效率,因为系统创建一个新线程代价是比较昂贵,每个创建的线程会复制当前执行的整个上下文。
尽可能的重用线程可以让我们的程序更高效。
一个简单的worker例子:
<"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并不会影响其他线程。
把上面的代码修改一下:
<"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调用。
<"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。
<"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程序设计有所帮助。
免责声明:本站资源来自互联网收集,仅供用于学习和交流,请遵循相关法律法规,本站一切资源不代表本站立场,如有侵权、后门、不妥请联系本站删除!
稳了!魔兽国服回归的3条重磅消息!官宣时间再确认!
昨天有一位朋友在大神群里分享,自己亚服账号被封号之后居然弹出了国服的封号信息对话框。
这里面让他访问的是一个国服的战网网址,com.cn和后面的zh都非常明白地表明这就是国服战网。
而他在复制这个网址并且进行登录之后,确实是网易的网址,也就是我们熟悉的停服之后国服发布的暴雪游戏产品运营到期开放退款的说明。这是一件比较奇怪的事情,因为以前都没有出现这样的情况,现在突然提示跳转到国服战网的网址,是不是说明了简体中文客户端已经开始进行更新了呢?