基于PHP pthreads實現多線程代碼實例
在某些情況,我們要使用 PHP 進行重復的任務,但是只能完成單次,疊加起來的話執行時間會非常長,所以就要將任務分配到多個線程來分別執行。
但 PHP 在默認情況下是沒有多線程的,必須要使用 pthreads PHP 擴展,這個擴展能真正的支持和實現多線程。多線程在處理重復性的循環任務,能夠大大縮短程序執行時間。
要使用這個擴展,就必須使用線程安全的版本。
在編譯 PHP 的時候, ?enable-maintainer-zts 這個選項是必須的,其他的根據自己的需求來添加
<?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 = ’暫無,第一次運行.’; $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個線程池,將他們都激活后,按照任務的數量來分配到每個線程上。
當一個線程完成他的工作后,繼續拿到下個任務繼續執行,直到所有任務都完成為止。
最后判斷是否全部執行完了,并停止線程的運行,釋放內存。
以上就是本文的全部內容,希望對大家的學習有所幫助,也希望大家多多支持好吧啦網。
相關文章:
