PHP pthreads v3下worker和pool的使用方法示例
本文實(shí)例講述了PHP pthreads v3下worker和pool的使用方法。分享給大家供大家參考,具體如下:
有些人會(huì)想,明明用thread已經(jīng)可以很好的工作了,為什么還要搞個(gè)worker和pool?
之所以要用到worker和pool還是因?yàn)樾?,因?yàn)橄到y(tǒng)創(chuàng)建一個(gè)新線程代價(jià)是比較昂貴,每個(gè)創(chuàng)建的線程會(huì)復(fù)制當(dāng)前執(zhí)行的整個(gè)上下文。
盡可能的重用線程可以讓我們的程序更高效。
一個(gè)簡(jiǎn)單的worker例子:
<?php //創(chuàng)建自定義work類,給work取個(gè)名字,方便查看 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() { //計(jì)算累加和 $total = 0; for ($i = 0; $i < $this->num; $i++) { $total += $i; } echo "work : {$this->worker->getName()} task : {$total} \n"; sleep(1); } } //創(chuàng)建一個(gè)worker線程 $work = new Work('a'); $work->start(); for ($i = 1; $i <= 10; $i++) { //將Task對(duì)象壓棧到worker線程中 //這個(gè)時(shí)候Task對(duì)象就可以使用worker線程上下文(變量,函數(shù)等) $work->stack(new Task($i)); } //循環(huán)的清理任務(wù),會(huì)阻塞主線程,直到棧中任務(wù)都執(zhí)行完畢 while ($work->collect()) ; //關(guān)閉worker $work->shutdown();
上面代碼在運(yùn)行的時(shí)候,計(jì)算結(jié)果會(huì)每隔一秒出來一條,也就是10個(gè)task對(duì)象是運(yùn)行在1個(gè)worker線程上的。
如果10個(gè)task對(duì)象是分別在獨(dú)立空間運(yùn)行的,sleep()函數(shù)就不會(huì)起作用,他們各自sleep并不會(huì)影響其他線程。
把上面的代碼修改一下:
<?php //創(chuàng)建自定義work類,給work取個(gè)名字,方便查看 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() { //計(jì)算累加和 $total = 0; for ($i = 0; $i < $this->num; $i++) { $total += $i; } echo "work : {$this->worker->getName()} task : {$total} \n"; sleep(1); } } //創(chuàng)建二個(gè)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)); } } //循環(huán)的清理任務(wù),會(huì)阻塞主線程,直到棧中任務(wù)都執(zhí)行完畢 while ($work1->collect() || $work2->collect()) ; //關(guān)閉worker $work1->shutdown(); $work2->shutdown();
這里我們創(chuàng)建2個(gè)worker線程,讓10個(gè)task對(duì)象分別壓棧到2個(gè)worker中。
這時(shí)可以看到,計(jì)算結(jié)果是一對(duì)一對(duì)的出來,說明10個(gè)task對(duì)象跑在了2個(gè)worker線程上。
至于需要?jiǎng)?chuàng)建多少個(gè)worker線程,和多少個(gè)task對(duì)象,就看自已的需求了。
worker還有一個(gè)好處就是可以重用worker中的對(duì)象和方法。我們可以在worker中創(chuàng)建一個(gè)連接數(shù)據(jù)庫對(duì)象,方便各task調(diào)用。
<?php class DB extends Worker { //注意這里設(shè)置為靜態(tài)成員,pdo連接本身是不能在上下文中共享的 //聲明為靜態(tài)成員,讓每個(gè)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; //注意,這里不要給成員設(shè)置默認(rèn)值,$result成員是線程對(duì)象是不可變的,不能被改寫 private $result; public function __construct($id) { $this->id = $id; } public function run() { //獲取worker中的數(shù)據(jù)庫連接 $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"; } } //創(chuàng)建一個(gè)worker線程 $work = new DB(); $work->start(); for ($i = 1; $i <= 5; $i++) { $work->stack(new Task($i)); } //循環(huán)的清理任務(wù),會(huì)阻塞主線程,直到棧中任務(wù)都執(zhí)行完畢 while ($work->collect()) ; //關(guān)閉worker $work->shutdown();
tb_user表大家可以隨意創(chuàng)建,我這里為了演示只創(chuàng)建了id和name字段
運(yùn)行結(jié)果如下:
如果說worker是對(duì)線程的重用,那么pool就是對(duì)worker更高的抽象了,可以同時(shí)管理多個(gè)worker。
<?php //之所以要?jiǎng)?chuàng)建一個(gè)Id線程類,主要是為了給work取個(gè)不同的ID,方便查看,哪些task線程屬于哪個(gè)work中 class Id extends Thread { private $id; public function getId() { //防止出現(xiàn)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; } //計(jì)算累加和 public function run() { $total = 0; for ($i = 0; $i < $this->num; $i++) { $total += $i; } echo "work id : {$this->worker->getId()} task : {$total} \n"; } } //創(chuàng)建pool,可容納3個(gè)work對(duì)象 $pool = new Pool(3, 'Work', [new Id()]); //循環(huán)的把20個(gè)task線程提交到pool中的work對(duì)象上運(yùn)行 for ($i = 1; $i <= 20; $i++) { $pool->submit(new Task($i)); } //循環(huán)的清理任務(wù),會(huì)阻塞主線程,直到任務(wù)都執(zhí)行完畢 while ($pool->collect()) ; //關(guān)閉pool $pool->shutdown();
運(yùn)行結(jié)果如下:
更多關(guān)于PHP相關(guān)內(nèi)容感興趣的讀者可查看本站專題:《PHP進(jìn)程與線程操作技巧總結(jié)》、《PHP網(wǎng)絡(luò)編程技巧總結(jié)》、《PHP基本語法入門教程》、《PHP數(shù)組(Array)操作技巧大全》、《php字符串(string)用法總結(jié)》、《php+mysql數(shù)據(jù)庫操作入門教程》及《php常見數(shù)據(jù)庫操作技巧匯總》
希望本文所述對(duì)大家PHP程序設(shè)計(jì)有所幫助。
相關(guān)文章
php計(jì)算給定日期所在周的開始日期和結(jié)束日期示例
這篇文章主要介紹了php計(jì)算給定日期所在周的開始日期和結(jié)束日期,涉及php日期與時(shí)間相關(guān)運(yùn)算與轉(zhuǎn)換技巧,具有一定參考借鑒價(jià)值,需要的朋友可以參考下2017-02-02PHP實(shí)現(xiàn)通過CURL上傳文件功能示例
這篇文章主要介紹了PHP實(shí)現(xiàn)通過CURL上傳文件功能,結(jié)合實(shí)例形式分析了php使用curl文件上傳操作相關(guān)屬性設(shè)置與使用技巧,需要的朋友可以參考下2018-05-05PHP實(shí)現(xiàn)表單提交數(shù)據(jù)的驗(yàn)證處理功能【防SQL注入和XSS攻擊等】
這篇文章主要介紹了PHP實(shí)現(xiàn)表單提交數(shù)據(jù)的驗(yàn)證處理功能,可實(shí)現(xiàn)防SQL注入和XSS攻擊等,涉及php字符處理、編碼轉(zhuǎn)換相關(guān)操作技巧,需要的朋友可以參考下2017-07-07php啟動(dòng)時(shí)候提示PHP startup的解決方法
配置好php環(huán)境后,每次開機(jī)都有警告提示說 PHP startup,解決這個(gè)問題很簡(jiǎn)單只需要在php.ini 文件中修改 extension_dir配置就行2013-05-05Php中文件下載功能實(shí)現(xiàn)超詳細(xì)流程分析
瀏覽器發(fā)送一個(gè)請(qǐng)求,請(qǐng)求訪問服務(wù)器中的某個(gè)網(wǎng)頁(如:down.php),該網(wǎng)頁的代碼如下2012-06-06