欧美bbbwbbbw肥妇,免费乱码人妻系列日韩,一级黄片

PHP pthreads v3下worker和pool的使用方法示例

 更新時間:2020年02月21日 10:52:30   作者:懷素真  
這篇文章主要介紹了PHP pthreads v3下worker和pool的使用方法,結(jié)合實例形式分析了PHP pthreads v3下worker和pool的基本功能、原理、使用方法及相關(guān)操作注意事項,需要的朋友可以參考下

本文實例講述了PHP pthreads v3下worker和pool的使用方法。分享給大家供大家參考,具體如下:

有些人會想,明明用thread已經(jīng)可以很好的工作了,為什么還要搞個worker和pool?

之所以要用到worker和pool還是因為效率,因為系統(tǒng)創(chuàng)建一個新線程代價是比較昂貴,每個創(chuàng)建的線程會復(fù)制當(dāng)前執(zhí)行的整個上下文。

盡可能的重用線程可以讓我們的程序更高效。

一個簡單的worker例子:

<?php
//創(chuàng)建自定義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);
  }
}

//創(chuàng)建一個worker線程
$work = new Work('a');

$work->start();

for ($i = 1; $i <= 10; $i++) {
  //將Task對象壓棧到worker線程中
  //這個時候Task對象就可以使用worker線程上下文(變量,函數(shù)等)
  $work->stack(new Task($i));
}

//循環(huán)的清理任務(wù),會阻塞主線程,直到棧中任務(wù)都執(zhí)行完畢
while ($work->collect()) ;

//關(guān)閉worker
$work->shutdown();

上面代碼在運行的時候,計算結(jié)果會每隔一秒出來一條,也就是10個task對象是運行在1個worker線程上的。

如果10個task對象是分別在獨立空間運行的,sleep()函數(shù)就不會起作用,他們各自sleep并不會影響其他線程。

把上面的代碼修改一下:

<?php
//創(chuàng)建自定義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);
  }
}

//創(chuàng)建二個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ù),會阻塞主線程,直到棧中任務(wù)都執(zhí)行完畢
while ($work1->collect() || $work2->collect()) ;

//關(guān)閉worker
$work1->shutdown();
$work2->shutdown();

這里我們創(chuàng)建2個worker線程,讓10個task對象分別壓棧到2個worker中。

這時可以看到,計算結(jié)果是一對一對的出來,說明10個task對象跑在了2個worker線程上。

至于需要創(chuàng)建多少個worker線程,和多少個task對象,就看自已的需求了。

worker還有一個好處就是可以重用worker中的對象和方法。我們可以在worker中創(chuàng)建一個連接數(shù)據(jù)庫對象,方便各task調(diào)用。

<?php
class DB extends Worker
{
  //注意這里設(shè)置為靜態(tài)成員,pdo連接本身是不能在上下文中共享的
  //聲明為靜態(tài)成員,讓每個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è)置默認值,$result成員是線程對象是不可變的,不能被改寫
  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)建一個worker線程
$work = new DB();

$work->start();

for ($i = 1; $i <= 5; $i++) {
  $work->stack(new Task($i));
}

//循環(huán)的清理任務(wù),會阻塞主線程,直到棧中任務(wù)都執(zhí)行完畢
while ($work->collect()) ;

//關(guān)閉worker
$work->shutdown();

tb_user表大家可以隨意創(chuàng)建,我這里為了演示只創(chuàng)建了id和name字段

運行結(jié)果如下:

 

如果說worker是對線程的重用,那么pool就是對worker更高的抽象了,可以同時管理多個worker。

<?php
//之所以要創(chuàng)建一個Id線程類,主要是為了給work取個不同的ID,方便查看,哪些task線程屬于哪個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;
  }

  //計算累加和
  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個work對象
$pool = new Pool(3, 'Work', [new Id()]);

//循環(huán)的把20個task線程提交到pool中的work對象上運行
for ($i = 1; $i <= 20; $i++) {
  $pool->submit(new Task($i));
}

//循環(huán)的清理任務(wù),會阻塞主線程,直到任務(wù)都執(zhí)行完畢
while ($pool->collect()) ;

//關(guān)閉pool
$pool->shutdown();

運行結(jié)果如下:

更多關(guān)于PHP相關(guān)內(nèi)容感興趣的讀者可查看本站專題:《PHP進程與線程操作技巧總結(jié)》、《PHP網(wǎng)絡(luò)編程技巧總結(jié)》、《PHP基本語法入門教程》、《PHP數(shù)組(Array)操作技巧大全》、《php字符串(string)用法總結(jié)》、《php+mysql數(shù)據(jù)庫操作入門教程》及《php常見數(shù)據(jù)庫操作技巧匯總

希望本文所述對大家PHP程序設(shè)計有所幫助。

相關(guān)文章

  • 利用php操作memcache緩存的基礎(chǔ)方法示例

    利用php操作memcache緩存的基礎(chǔ)方法示例

    Memcache函數(shù)庫是在PECL(PHP Extension Community Library)中,主要作用是搭建大容量的內(nèi)存數(shù)據(jù)的臨時存放區(qū)域,在分布式的時候作用體現(xiàn)的非常明顯,否則不建議使用。本文將給大家介紹了關(guān)于利用php操作memcache緩存的基礎(chǔ)方法,需要的朋友可以參考下。
    2017-08-08
  • php計算給定日期所在周的開始日期和結(jié)束日期示例

    php計算給定日期所在周的開始日期和結(jié)束日期示例

    這篇文章主要介紹了php計算給定日期所在周的開始日期和結(jié)束日期,涉及php日期與時間相關(guān)運算與轉(zhuǎn)換技巧,具有一定參考借鑒價值,需要的朋友可以參考下
    2017-02-02
  • PHP實現(xiàn)通過CURL上傳文件功能示例

    PHP實現(xiàn)通過CURL上傳文件功能示例

    這篇文章主要介紹了PHP實現(xiàn)通過CURL上傳文件功能,結(jié)合實例形式分析了php使用curl文件上傳操作相關(guān)屬性設(shè)置與使用技巧,需要的朋友可以參考下
    2018-05-05
  • PHP實現(xiàn)表單提交數(shù)據(jù)的驗證處理功能【防SQL注入和XSS攻擊等】

    PHP實現(xiàn)表單提交數(shù)據(jù)的驗證處理功能【防SQL注入和XSS攻擊等】

    這篇文章主要介紹了PHP實現(xiàn)表單提交數(shù)據(jù)的驗證處理功能,可實現(xiàn)防SQL注入和XSS攻擊等,涉及php字符處理、編碼轉(zhuǎn)換相關(guān)操作技巧,需要的朋友可以參考下
    2017-07-07
  • 54個提高PHP程序運行效率的方法

    54個提高PHP程序運行效率的方法

    本文給大家分享的是個人總結(jié)的關(guān)于提高PHP程序運行效率的方法,有相同需求的小伙伴可以來參考下。
    2015-07-07
  • Fastadmin框架自定義搜索操作流程

    Fastadmin框架自定義搜索操作流程

    這篇文章主要介紹了Fastadmin框架自定義搜索操作流程,包括html標(biāo)簽、js調(diào)整、PHP修改,需要的朋友可以參考下
    2023-08-08
  • php啟動時候提示PHP startup的解決方法

    php啟動時候提示PHP startup的解決方法

    配置好php環(huán)境后,每次開機都有警告提示說 PHP startup,解決這個問題很簡單只需要在php.ini 文件中修改 extension_dir配置就行
    2013-05-05
  • php防止CC攻擊代碼 php防止網(wǎng)頁頻繁刷新

    php防止CC攻擊代碼 php防止網(wǎng)頁頻繁刷新

    這篇文章主要介紹了php防止CC攻擊代碼和php防止網(wǎng)頁頻繁刷新,網(wǎng)頁快速惡意刷新,cc攻擊利用代理服務(wù)器生成指向目標(biāo)站點的合法請求,模擬多用戶不停的對受害網(wǎng)站進行訪問,感興趣的小伙伴們可以研究一下
    2015-12-12
  • Php中文件下載功能實現(xiàn)超詳細流程分析

    Php中文件下載功能實現(xiàn)超詳細流程分析

    瀏覽器發(fā)送一個請求,請求訪問服務(wù)器中的某個網(wǎng)頁(如:down.php),該網(wǎng)頁的代碼如下
    2012-06-06
  • PHP臨時文件的安全性分析

    PHP臨時文件的安全性分析

    這篇文章主要介紹了PHP臨時文件的安全性分析,對于臨時文件的安全性及防范措施作出了比較詳細的闡述,需要的朋友可以參考下
    2014-07-07

最新評論