線程是我們在做項(xiàng)目中首要考慮的，在php中怎么實(shí)現(xiàn)線程呢，我們這里就看看PHP線程的實(shí)現(xiàn)。許多 PHP 開發(fā)人員認(rèn)為，由于標(biāo)準(zhǔn)的 PHP 缺少線程功能，因此實(shí)際 PHP 應(yīng)用程序不可能執(zhí)行多任務(wù)處理。

例如，如果應(yīng)用程序需要其他 Web 站點(diǎn)的信息，那么在遠(yuǎn)程檢索完成之前它都必須停止。這是錯誤的！通過本文了解如何使用 stream_select 和 stream_socket_client 實(shí)現(xiàn)進(jìn)程內(nèi) PHP 多任務(wù)處理。PHP 不支持線程。盡管如此，與前述大多數(shù) PHP 開發(fā)人員所相信的想法形成對比的是，PHP 應(yīng)用程序可以 執(zhí)行多任務(wù)處理。讓我們開始盡可能清晰地描述一下 “多任務(wù)” 和 “線程” 對于 PHP 編程的意義。

PHP線程并發(fā)的種類

首先拋開幾個和主題無關(guān)的例子。PHP 與多任務(wù)或并發(fā)的關(guān)系十分復(fù)雜。在較高層次上，PHP 經(jīng)常涉及多任務(wù)：以多任務(wù)方式使用 標(biāo)準(zhǔn)的服務(wù)器端 PHP 安裝 —— 例如，作為 Apache 模塊。換句話說，若干個客戶機(jī) —— Web 瀏覽器 —— 可以同時(shí)請求同一個 PHP 解釋的頁面，而 Web 服務(wù)器將差不多同時(shí)返回所有這些頁面。

一個 Web 頁面不會妨礙其他 Web 頁面的發(fā)送，盡管可能會由于諸如服務(wù)器內(nèi)存或網(wǎng)絡(luò)帶寬之類的受限資源而使它們相互之間略有妨礙。這樣，實(shí)現(xiàn)并發(fā) 的系統(tǒng)級需求可能適合使用基于 PHP 的解決方案。就實(shí)現(xiàn)而言，PHP 允許它的管理 Web 服務(wù)器負(fù)責(zé)實(shí)現(xiàn)并發(fā)。

Ajax 名下的客戶端并發(fā)近幾年來也已成為開發(fā)人員關(guān)注的焦點(diǎn)。雖然 Ajax 的含義已經(jīng)變得十分模糊，但是它的一個方面是瀏覽器顯示可以同時(shí)執(zhí)行計(jì)算和保留對諸如選擇菜單項(xiàng)之類的用戶操作的響應(yīng)。這實(shí)際上就是某種 多任務(wù)。用 PHP 編碼的 Ajax 就是這樣 —— 但是不涉及任何特定的 PHP；用于其他語言的 Ajax 框架均以完全相同的方法操作。

只粗略地涉及 PHP 的第三個并發(fā)實(shí)例是 PHP/TK。PHP/TK 是 PHP 的擴(kuò)展，用于為核心 PHP 提供可移植圖形用戶界面（GUI）綁定。PHP/TK 允許用 PHP 編寫代碼構(gòu)造桌面 GUI 應(yīng)用程序。其基于事件的特性將模擬一種易于掌握并且比線程更少出錯的并發(fā)形式。此外，并發(fā)是 “繼承” 自一項(xiàng)輔助技術(shù)，而不是 PHP 的基本功能。

#T#向 PHP 本身添加線程支持的試驗(yàn)已經(jīng)做過多次。據(jù)我所知，沒有一次是成功的。但是，Ajax 框架和 PHP/TK 的面向事件的實(shí)現(xiàn)表明事件可能比線程能更好地體現(xiàn) PHP 的并發(fā)。PHP V5 證明事實(shí)確實(shí)如此。使用標(biāo)準(zhǔn)的 PHP V4 和更低版本，必須按順序執(zhí)行 PHP 應(yīng)用程序的所有工作。例如，如果程序需要在兩個商業(yè)站點(diǎn)檢索商品的價(jià)格，則請求第一個站點(diǎn)的價(jià)格，等待至響應(yīng)到達(dá)，再請求第二個站點(diǎn)的價(jià)格，然后再次等待。如果程序請求同時(shí)完成若干項(xiàng)任務(wù)會怎么樣？總體來看，程序?qū)⒃谝欢螘r(shí)間內(nèi)完成，在這段時(shí)間內(nèi)，將始終進(jìn)行連續(xù)處理。

第一個示例PHP線程新的 stream_select 函數(shù)及它的幾個助手使這成為可能。請考慮以下示例。

清單 1. 同時(shí)請求多個 HTTP 頁面

＜?php  
echo "Program starts at ". date('h:i:s') . ".\n";  
 
$timeout=10;  
$result=array();  
$sockets=array();  
$convenient_read_block=8192;  
 
/* Issue all requests simultaneously; there's no blocking. */  
$delay=15;  
$id=0;  
while ($delay ＞ 0) {  
$s=stream_socket_client("phaseit.net:80", $errno,  
$errstr, $timeout,  
STREAM_CLIENT_ASYNC_CONNECT|STREAM_CLIENT_CONNECT);  
if ($s) {  
$sockets[$id++]=$s;  
$http_message="GET /demonstration/delay?delay=" .  
$delay . " HTTP/1.0\r\nHost: phaseit.net\r\n\r\n";  
fwrite($s, $http_message);  
} else {  
echo "Stream " . $id . " failed to open correctly.";  
}  
$delay -= 3;  
}  
 
while (count($sockets)) {  
$read=$sockets;  
stream_select($read, $w=null, $e=null, $timeout);  
if (count($read)) {  
/* stream_select generally shuffles $read, so we need to  
compute from which socket(s) we're reading. */  
foreach ($read as $r) {  
$id=array_search($r, $sockets);  
$data=fread($r, $convenient_read_block);  
/* A socket is readable either because it has  
data to read, OR because it's at EOF. */  
if (strlen($data) == 0) {  
echo "Stream " . $id . " closes at " . date('h:i:s') . ".\n";  
fclose($r);  
unset($sockets[$id]);  
} else {  
$result[$id] .= $data;  
}  
}  
} else {  
/* A time-out means that *all* streams have failed  
to receive a response. */  
echo "Time-out!\n";  
break;  
}  
}  
?＞  

如果運(yùn)行此清單，您將看到如下所示的輸出。