本文例項講述了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();

這裡我們建立2個worker執行緒，讓10個task物件分別壓棧到2個worker中。

這時可以看到，計算結果是一對一對的出來，說明10個task物件跑在了2個worker執行緒上。

至於需要建立多少個worker執行緒，和多少個task物件，就看自已的需求了。

worker還有一個好處就是可以重用worker中的物件和方法。我們可以在worker中建立一個連線資料庫物件，方便各task呼叫。

<?php
class DB extends Worker
{
  //注意這裡設定為靜態成員，pdo連線本身是不能在上下文中共享的
  //宣告為靜態成員，讓每個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;
  //注意，這裡不要給成員設定預設值，$result成員是執行緒物件是不可變的，不能被改寫
  private $result;

  public function __construct($id)
  {
    $this->id = $id;
  }

  public function run()
  {
    //獲取worker中的資料庫連線
    $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";
  }
}

//建立一個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。

<?php
//之所以要建立一個Id執行緒類，主要是為了給work取個不同的ID，方便檢視，哪些task執行緒屬於哪個work中
class Id extends Thread
{
  private $id;

  public function getId()
  {
    //防止出現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;
  }

  //計算累加和
  public function run()
  {
    $total = 0;
    for ($i = 0; $i < $this->num; $i++) {
      $total += $i;
    }
    echo "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程式設計有所幫助。