基于PHP pthreads實(shí)現(xiàn)多線程代碼實(shí)例

更新時(shí)間：2020年06月24日 09:45:44 作者：楓之落葉

這篇文章主要介紹了基于PHP pthreads實(shí)現(xiàn)多線程代碼實(shí)例,文中通過示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友可以參考下

在某些情況，我們要使用 PHP 進(jìn)行重復(fù)的任務(wù)，但是只能完成單次，疊加起來的話執(zhí)行時(shí)間會(huì)非常長，所以就要將任務(wù)分配到多個(gè)線程來分別執(zhí)行。

但 PHP 在默認(rèn)情況下是沒有多線程的，必須要使用 pthreads PHP 擴(kuò)展，這個(gè)擴(kuò)展能真正的支持和實(shí)現(xiàn)多線程。多線程在處理重復(fù)性的循環(huán)任務(wù)，能夠大大縮短程序執(zhí)行時(shí)間。

要使用這個(gè)擴(kuò)展，就必須使用線程安全的版本。

在編譯 PHP 的時(shí)候， –enable-maintainer-zts 這個(gè)選項(xiàng)是必須的，其他的根據(jù)自己的需求來添加

<?php

error_reporting(E_ALL);
class vote extends Thread {
  public $res  = '';
  public $url  = array();
  public $name  = '';
  public $runing = false;
  public $lc   = false;

  public function __construct($name) {
    $this->res  = '暫無,第一次運(yùn)行.';
    $this->param  = 0;
    $this->lurl  = 0;
    $this->name  = $name;
    $this->runing = true;
    $this->lc   = false;
  }

  public function run() {
    while ($this->runing) {

      if ($this->param != 0) {
        $nt     = rand(1, 10);
        echo time()."線程[{$this->name}]收到任務(wù)參數(shù)::{$this->param},需要{$nt}秒處理數(shù)據(jù).n";
        $this->res  = rand(100, 999);
        //sleep($nt);
        $this->lurl = $this->param;
        $this->param  = '';
      } else {
        echo time()."線程[{$this->name}]等待任務(wù)..n";
      }
      sleep(1);
    }
  }
}

//這里創(chuàng)建線程池.
$pool[] = new vote('a');
$pool[] = new vote('b');
$pool[] = new vote('c');
$pool[] = new vote('d');
$pool[] = new vote('e');
$pool[] = new vote('f');
$pool[] = new vote('g');
$pool[] = new vote('h');
$pool[] = new vote('i');
$pool[] = new vote('j');

//啟動(dòng)所有線程,使其處于工作狀態(tài)
foreach ($pool as $w) {
  $w->start();
}

//派發(fā)任務(wù)給線程
for ($i = 0; $i < 100; $i++) {
  $worker_content = rand(10, 99);
  while (true) {
    foreach ($pool as $worker) {
      //參數(shù)為空則說明線程空閑
      if ($worker->param=='') {
        $worker->param = $worker_content;
        echo "[{$worker->name}]線程空閑,放入?yún)?shù){$worker_content},上次參數(shù)[{$worker->lurl}]結(jié)果[{$worker->res}].n";
        break 2;
      }
    }
    sleep(1);
  }
}
echo "所有線程派發(fā)完畢,等待執(zhí)行完成.n";

//等待所有線程運(yùn)行結(jié)束
while (count($pool)) {
  //遍歷檢查線程組運(yùn)行結(jié)束
  foreach ($pool as $key => $threads) {
    if ($worker->param=='') {
      echo "[{$threads->name}]線程空閑,上次參數(shù)[{$threads->lurl}]結(jié)果[{$threads->res}].n";
      echo "[{$threads->name}]線程運(yùn)行完成,退出.n";
      //設(shè)置結(jié)束標(biāo)志
      $threads->runing = false;
      unset($pool[$key]);
    }
  }
  echo "等待中...n";
  sleep(1);
}
echo "所有線程執(zhí)行完畢.n";
?>

這段代碼首先是新建了10個(gè)線程池，將他們都激活后，按照任務(wù)的數(shù)量來分配到每個(gè)線程上。

當(dāng)一個(gè)線程完成他的工作后，繼續(xù)拿到下個(gè)任務(wù)繼續(xù)執(zhí)行，直到所有任務(wù)都完成為止。

最后判斷是否全部執(zhí)行完了，并停止線程的運(yùn)行，釋放內(nèi)存。

以上就是本文的全部內(nèi)容，希望對(duì)大家的學(xué)習(xí)有所幫助，也希望大家多多支持腳本之家。

您可能感興趣的文章: