本文實(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è)簡單的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ì)有所幫助。
您可能感興趣的文章:- PHP pthread拓展使用和注意點(diǎn)
- PHP pthreads v3下同步處理synchronized用法示例
- PHP pthreads v3使用中的一些坑和注意點(diǎn)分析
- php使用pthreads v3多線程實(shí)現(xiàn)抓取新浪新聞信息操作示例
- PHP中使用pthread拓展
