thread php,php中关于线程thread的使用
php通過擴(kuò)展pthreads也可以支持線程上的操作,在mac下可以通過brew安裝pthreads擴(kuò)展。
安裝pthreads擴(kuò)展
搜索pthreads
$ brew search pthreads
homebrew/php/php53-pthreads homebrew/php/php54-pthreads homebrew/php/php55-pthreads homebrew/php/php56-pthreads
根據(jù)不同的php版本進(jìn)行安裝,例如我是安裝php55-pthreads
$ brew install php55-pthreads
安裝完成后,記的重啟下web服務(wù)器。
線程測試
線程類要繼承Thread類,而后實現(xiàn)run方法。
class computer extends Thread {
public $id;
public $runing = false;
public $params = null;
public function __construct($id) {
$this->id = $id;
$this->runing = true;
}
public function run() {
while ($this->runing) {
if (is_null($this->params)) {
echo "線程({$this->id})等待任務(wù)...\n";
} else {
echo "線程({$this->id}) 收到任務(wù)參數(shù)::{$this->params}.\n";
$this->params = null;
}
sleep(1);
}
}
}
代碼很簡單,用running標(biāo)記線程是否在運行,params標(biāo)記外界傳遞的參數(shù),如果外界傳遞參數(shù)過來則可以運行。
使用該類
//這里創(chuàng)建線程池.
$pool = array(new computer('a'), new computer('b'), new computer('c'));
//啟動所有線程,使其處于工作狀態(tài)
foreach ($pool as $w) {
$w->start();
}
//派發(fā)任務(wù)給線程
for ($i = 0; $i < 10; $i++) {
$params = rand(10, 99);
while (true) {
foreach ($pool as $worker) {
//參數(shù)為空則說明線程空閑
if (is_null($worker->params)) {
$worker->params = $params;
echo "({$worker->id})線程空閑,放入?yún)?shù){$params}.\n";
break 2;
}
}
sleep(1);
}
}
//關(guān)閉線程
while (count($pool)) {
//遍歷檢查線程組運行結(jié)束
foreach ($pool as $key => $worker) {
if ($worker->params == '') {
echo "({$worker->id})線程運行完成,退出.\n";
//設(shè)置結(jié)束標(biāo)志
$worker->runing = false;
unset($pool[$key]);
}
}
echo "等待退出中...\n";
sleep(1);
}
echo "退出成功\n";
運行結(jié)果
在命令行中運行輸入結(jié)果參考如下:
$ php thread.php
線程(a)等待任務(wù)...
線程(b)等待任務(wù)...
線程(c)等待任務(wù)...
(a)線程空閑,放入?yún)?shù)21.
(b)線程空閑,放入?yún)?shù)97.
(c)線程空閑,放入?yún)?shù)54.
線程(a) 收到任務(wù)參數(shù)::21.
線程(b) 收到任務(wù)參數(shù)::97.
線程(c) 收到任務(wù)參數(shù)::54.
(a)線程空閑,放入?yún)?shù)68.
(b)線程空閑,放入?yún)?shù)71.
(c)線程空閑,放入?yún)?shù)58.
線程(a) 收到任務(wù)參數(shù)::68.
線程(b) 收到任務(wù)參數(shù)::71.
線程(c) 收到任務(wù)參數(shù)::58.
(a)線程空閑,放入?yún)?shù)79.
(b)線程空閑,放入?yún)?shù)20.
(c)線程空閑,放入?yún)?shù)18.
線程(a) 收到任務(wù)參數(shù)::79.
線程(b) 收到任務(wù)參數(shù)::20.
線程(c) 收到任務(wù)參數(shù)::18.
(a)線程空閑,放入?yún)?shù)76.
(b)線程運行完成,退出.
(c)線程運行完成,退出.
線程(a) 收到任務(wù)參數(shù)::76.
等待退出中...
線程(a)等待任務(wù)...
(a)線程運行完成,退出.
等待退出中...
退出成功
因為使用了sleep,在瀏覽器里運行估計要等結(jié)果輸出需要一段時間。這里還有一個問題可以考慮一下:這里的線程工作任務(wù)只是輸出內(nèi)容,如果需要得到返回的計算結(jié)果,和普通的函數(shù)調(diào)用返回不同,這里涉及到異步方面的問題,會復(fù)雜一些,后續(xù)再介紹吧。
總結(jié)
以上是生活随笔為你收集整理的thread php,php中关于线程thread的使用的全部內(nèi)容,希望文章能夠幫你解決所遇到的問題。
- 上一篇: php 网页截屏,怎么用PHP实现网页截
- 下一篇: cmf php,cmf公共函数解析-co