在某些情況，我們要使用 PHP 進行重複的任務，但是隻能完成單次，疊加起來的話執行時間會非常長，所以就要將任務分配到多個執行緒來分別執行。

但 PHP 在預設情況下是沒有多執行緒的，必須要使用 pthreads PHP 擴充套件，這個擴充套件能真正的支援和實現多執行緒。多執行緒在處理重複性的迴圈任務，能夠大大縮短程式執行時間。

要使用這個擴充套件，就必須使用執行緒安全的版本。

在編譯 PHP 的時候， –enable-maintainer-zts ​這個選項是必須的，其他的根據自己的需求來新增

<?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  = '暫無,第一次執行.';
    $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}]收到任務引數::{$this->param},需要{$nt}秒處理資料.n";
        $this->res  = rand(100,999);
        //sleep($nt);
        $this->lurl = $this->param;
        $this->param  = '';
      } else {
        echo time()."執行緒[{$this->name}]等待任務..n";
      }
      sleep(1);
    }
  }
}

//這裡建立執行緒池.
$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');

//啟動所有執行緒,使其處於工作狀態
foreach ($pool as $w) {
  $w->start();
}

//派發任務給執行緒
for ($i = 0; $i < 100; $i++) {
  $worker_content = rand(10,99);
  while (true) {
    foreach ($pool as $worker) {
      //引數為空則說明執行緒空閒
      if ($worker->param=='') {
        $worker->param = $worker_content;
        echo "[{$worker->name}]執行緒空閒,放入引數{$worker_content},上次引數[{$worker->lurl}]結果[{$worker->res}].n";
        break 2;
      }
    }
    sleep(1);
  }
}
echo "所有執行緒派發完畢,等待執行完成.n";

//等待所有執行緒執行結束
while (count($pool)) {
  //遍歷檢查執行緒組執行結束
  foreach ($pool as $key => $threads) {
    if ($worker->param=='') {
      echo "[{$threads->name}]執行緒空閒,上次引數[{$threads->lurl}]結果[{$threads->res}].n";
      echo "[{$threads->name}]執行緒執行完成,退出.n";
      //設定結束標誌
      $threads->runing = false;
      unset($pool[$key]);
    }
  }
  echo "等待中...n";
  sleep(1);
}
echo "所有執行緒執行完畢.n";
?>

這段程式碼首先是新建了10個執行緒池，將他們都啟用後，按照任務的數量來分配到每個執行緒上。

當一個執行緒完成他的工作後，繼續拿到下個任務繼續執行，直到所有任務都完成為止。

最後判斷是否全部執行完了，並停止執行緒的執行，釋放記憶體。

以上就是本文的全部內容，希望對大家的學習有所幫助，也希望大家多多支援我們。