這篇文章將為大家詳細講解有關PHP用threads實現多線程的方法 ，文章內容質量較高，因此小編分享給大家做個參考，希望大家閱讀完這篇文章后對相關知識有一定的了解。
在某些情況，我們要使用 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個線程池，將他們都激活后，按照任務的數量來分配到每個線程上。
當一個線程完成他的工作后，繼續拿到下個任務繼續執行，直到所有任務都完成為止。
最后判斷是否全部執行完了，并停止線程的運行，釋放內存。
關于PHP用threads實現多線程的方法 就分享到這里了，希望以上內容可以對大家有一定的幫助，可以學到更多知識。如果覺得文章不錯，可以把它分享出去讓更多的人看到。
免責聲明：本站發布的內容（圖片、視頻和文字）以原創、轉載和分享為主，文章觀點不代表本網站立場，如果涉及侵權請聯系站長郵箱：is@yisu.com進行舉報，并提供相關證據，一經查實，將立刻刪除涉嫌侵權內容。
