深入講解PHP線程并發(fā)種類(lèi)
線程是我們?cè)谧鲰?xiàng)目中首要考慮的，在php中怎么實(shí)現(xiàn)線程呢，我們這里就看看PHP線程的實(shí)現(xiàn)。許多 PHP 開(kāi)發(fā)人員認(rèn)為，由于標(biāo)準(zhǔn)的 PHP 缺少線程功能，因此實(shí)際 PHP 應(yīng)用程序不可能執(zhí)行多任務(wù)處理。
例如，如果應(yīng)用程序需要其他 Web 站點(diǎn)的信息，那么在遠(yuǎn)程檢索完成之前它都必須停止。這是錯(cuò)誤的！通過(guò)本文了解如何使用 stream_select 和 stream_socket_client 實(shí)現(xiàn)進(jìn)程內(nèi) PHP 多任務(wù)處理。PHP 不支持線程。盡管如此，與前述大多數(shù) PHP 開(kāi)發(fā)人員所相信的想法形成對(duì)比的是，PHP 應(yīng)用程序可以 執(zhí)行多任務(wù)處理。讓我們開(kāi)始盡可能清晰地描述一下 “多任務(wù)” 和 “線程” 對(duì)于 PHP 編程的意義。
PHP線程并發(fā)的種類(lèi)
首先拋開(kāi)幾個(gè)和主題無(wú)關(guān)的例子。PHP 與多任務(wù)或并發(fā)的關(guān)系十分復(fù)雜。在較高層次上，PHP 經(jīng)常涉及多任務(wù)：以多任務(wù)方式使用 標(biāo)準(zhǔn)的服務(wù)器端 PHP 安裝 —— 例如，作為 Apache 模塊。換句話說(shuō)，若干個(gè)客戶(hù)機(jī) —— Web 瀏覽器 —— 可以同時(shí)請(qǐng)求同一個(gè) PHP 解釋的頁(yè)面，而 Web 服務(wù)器將差不多同時(shí)返回所有這些頁(yè)面。
一個(gè) Web 頁(yè)面不會(huì)妨礙其他 Web 頁(yè)面的發(fā)送，盡管可能會(huì)由于諸如服務(wù)器內(nèi)存或網(wǎng)絡(luò)帶寬之類(lèi)的受限資源而使它們相互之間略有妨礙。這樣，實(shí)現(xiàn)并發(fā) 的系統(tǒng)級(jí)需求可能適合使用基于 PHP 的解決方案。就實(shí)現(xiàn)而言，PHP 允許它的管理 Web 服務(wù)器負(fù)責(zé)實(shí)現(xiàn)并發(fā)。
Ajax 名下的客戶(hù)端并發(fā)近幾年來(lái)也已成為開(kāi)發(fā)人員關(guān)注的焦點(diǎn)。雖然 Ajax 的含義已經(jīng)變得十分模糊，但是它的一個(gè)方面是瀏覽器顯示可以同時(shí)執(zhí)行計(jì)算和保留對(duì)諸如選擇菜單項(xiàng)之類(lèi)的用戶(hù)操作的響應(yīng)。這實(shí)際上就是某種 多任務(wù)。用 PHP 編碼的 Ajax 就是這樣 —— 但是不涉及任何特定的 PHP；用于其他語(yǔ)言的 Ajax 框架均以完全相同的方法操作。
只粗略地涉及 PHP 的第三個(gè)并發(fā)實(shí)例是 PHP/TK。PHP/TK 是 PHP 的擴(kuò)展，用于為核心 PHP 提供可移植圖形用戶(hù)界面（GUI）綁定。PHP/TK 允許用 PHP 編寫(xiě)代碼構(gòu)造桌面 GUI 應(yīng)用程序。其基于事件的特性將模擬一種易于掌握并且比線程更少出錯(cuò)的并發(fā)形式。此外，并發(fā)是 “繼承” 自一項(xiàng)輔助技術(shù)，而不是 PHP 的基本功能。
#T#向 PHP 本身添加線程支持的試驗(yàn)已經(jīng)做過(guò)多次。據(jù)我所知，沒(méi)有一次是成功的。但是，Ajax 框架和 PHP/TK 的面向事件的實(shí)現(xiàn)表明事件可能比線程能更好地體現(xiàn) PHP 的并發(fā)。PHP V5 證明事實(shí)確實(shí)如此。使用標(biāo)準(zhǔn)的 PHP V4 和更低版本，必須按順序執(zhí)行 PHP 應(yīng)用程序的所有工作。例如，如果程序需要在兩個(gè)商業(yè)站點(diǎn)檢索商品的價(jià)格，則請(qǐng)求第一個(gè)站點(diǎn)的價(jià)格，等待至響應(yīng)到達(dá)，再請(qǐng)求第二個(gè)站點(diǎn)的價(jià)格，然后再次等待。如果程序請(qǐng)求同時(shí)完成若干項(xiàng)任務(wù)會(huì)怎么樣？總體來(lái)看，程序?qū)⒃谝欢螘r(shí)間內(nèi)完成，在這段時(shí)間內(nèi)，將始終進(jìn)行連續(xù)處理。
第一個(gè)示例PHP線程新的 stream_select 函數(shù)及它的幾個(gè)助手使這成為可能。請(qǐng)考慮以下示例。
清單 1. 同時(shí)請(qǐng)求多個(gè) HTTP 頁(yè)面
- ＜?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)行此清單，您將看到如下所示的輸出。
