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

但 PHP 在默認(rèn)情況下是沒(méi)有多線程的，必須要使用 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ù)自己的需求來(lái)添加

<?phperror_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 = ’暫無(wú),第一次運(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ù)為空則說(shuō)明線程空閑 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ù)量來(lái)分配到每個(gè)線程上。

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

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

以上就是本文的全部?jī)?nèi)容，希望對(duì)大家的學(xué)習(xí)有所幫助，也希望大家多多支持好吧啦網(wǎng)。