當前位置:才華齋>計算機>php語言>

PHP實現多執行緒方法兩個

php語言 閱讀(4.98K)

導語:PHP如何實現多執行緒呢?下面是小編給大家提供的PHP實現多執行緒方法兩個,大家可以參考閱讀,更多詳情請關注應屆畢業生考試網。

PHP實現多執行緒方法兩個

先寫個簡單的php程式碼,這裡為了讓指令碼執行時間更長,方便看效果,sleep一下,呵呵!先看下的程式碼:ls

PHP程式碼:

<?php

for ($i=0;$i<10;$i++) {

echo $i;

sleep(10);

}

?>

在看下shell指令碼的程式碼,非常簡單

#!/bin/bash

for i in 1 2 3 4 5 6 7 8 9 10

do

/usr/bin/php -q /var/www/html/ &

done

注意到在請求php程式碼的那行有一個&符號嗎,這個是關鍵,不加的話是不能進行多執行緒的,&表示講服務推送到後臺執行,因此,在 shell的每次的迴圈中不必等php的程式碼全部執行完在請求下一個檔案,而是同時進行的,這樣就實現了多執行緒,下面執行下shell看下效果,這裡你將 看到10個程序再跑,再利用linux的定時器,定時請求這個shell,在處理一些需要多執行緒的任務,例如,批量下載時,非常好用!

php中用WEB伺服器實現多執行緒

假設我們現在執行的是這個檔案. 但是我在程式中又請求WEB伺服器執行另一個,那麼這兩個檔案將是同時執行的.(PS: 一個連結請求傳送之後, WEB伺服器就會執行它, 而不管客戶端是否已經退出)

有些時候, 我們想執行的不是另一個檔案, 而是本檔案中的一部分程式碼.該怎麼辦呢?

其實可是通過引數來控制來執行哪一段程式.

下面看一個例子:

//,

PHP程式碼:--------------------------------------------------------------------------------

<?php

function runThread()

{

$fp = fsockopen('localhost', 80, $errno, $errmsg);

fputs($fp, "GET /rnrn"); //這裡的第二個引數是HTTP協議中規定的請求頭

//不明白的請看RFC中的定義

fclose($fp);

}

function a()

{

$fp = fopen('result_', 'w');

fputs($fp, 'Set in ' . Date('h:i:s', time()) . (double)microtime() . "rn");

fclose($fp);

}

function b()

{

$fp = fopen('result_', 'w');

fputs($fp, 'Set in ' . Date('h:i:s', time()) . (double)microtime() . "rn");

fclose($fp);

}

if(!isset($_GET['act'])) $_GET['act'] = 'a';

if($_GET['act'] == 'a')

{

runThread();

a();

}

else if($_GET['act'] == 'b') b();

?>

--------------------------------------------------------------------------------

開啟result_ 和 result_ 比較一下兩個檔案的中訪問的時間. 大家會發現, 這兩個的確是在不同執行緒中執行的.有些時間完全一樣.

上面只是一個簡單的例子, 大家可以改進成其它形式.

既然PHP中也能多執行緒了, 那麼問題也來了, 那就是同步的問題. 我們知道 PHP本身是不支援多執行緒的. 所以更不會有什麼像Java 中synchronize的方法了. 那我們該如何做呢.

1. 儘量不訪問同一個資源. 以避免衝突. 但是可以同時像資料庫操作. 因為資料庫是支援併發操作的. 所以在多執行緒的PHP中不要向同一個檔案中寫入資料. 如果必須要寫的話, 用別的方法進行同步.. 如呼叫 flock對檔案進行加鎖等. 或建立臨時檔案並在另外的執行緒中等待這個檔案的消失 while(file_exits('xxx')); 這樣就等於這個臨時檔案存在時, 表示其實執行緒正在操作

如果沒有了這個檔案, 說明其它執行緒已經釋放了這個.

2. 儘量不要從runThread在執行fputs後取這個socket中讀取資料. 因為要實現多執行緒, 需要的用非阻塞模式. 即在像fgets這樣的函式時立即返回.. 所以讀寫資料就會出問題. 如果使用阻塞模式的話, 程式就不算是多執行緒了. 他要等上面的返回才執行下面的程式. 所以如果需要交換資料最後利用外面檔案或資料中完成. 實在想要的話就用socket_set_nonblock($fp) 來實現.

說了這麼多, 倒底這個有沒有實際的意義呢? 在什麼時候需要這種用這種方法呢 ?

答案是肯定的. 大家知道. 在一個不斷讀取網路資源的應用中, 網路的速度是瓶頸. 如果採多這種形式就可以同時以多個執行緒對不同的頁面進行讀取.

本人做的一個能從8848、soaso這些商城網站搜尋資訊的程式。還有一個從阿里巴巴網站上讀取商業資訊和公司目錄的程式也用到了此技術。 因為這兩個程式都是要不斷的連結它們的伺服器讀取資訊並儲存到資料庫。 利用此技術正好消除了在等待響應時的.瓶頸。

php模擬實現多執行緒的三種方法

PHP語言本身是不支援多執行緒的. 總結了一下網上關於PHP模擬多執行緒的方法, 總的來說, 都是利用了PHP的好夥伴們本身所具有的多執行緒能力. PHP的好夥伴指的就是LINUX和APACHE啦, LAMP嘛.

另外, 既然是模擬的, 就不是真正的多執行緒. 其實只是多程序. 程序和執行緒是兩個不同的概念. 好了, 以下方法都是從網上找來的.

1. 利用LINUX作業系統

<?php

for ($i=0;$i<10;$i++) {

echo $i;

sleep(5);

}

?>

上面存成, 然後寫一段SHELL程式碼

#!/bin/bash

for i in 1 2 3 4 5 6 7 8 9 10

do

php -q &

done

2. 利用fork子程序(其實同樣是利用LINUX作業系統)

<?php

declare(ticks=1);

$bWaitFlag = FALSE; /// 是否等待程序結束

$intNum = 10; /// 程序總數

$pids = array(); /// 程序PID陣列

echo ("Startn");

for($i = 0; $i < $intNum; $i++) {

$pids[$i] = pcntl_fork();/// 產生子程序,而且從當前行之下開試執行程式碼,而且不繼承父程序的資料資訊

if(!$pids[$i]) {

// 子程序程序程式碼段_Start

$str="";

sleep(5+$i);

for ($j=0;$j<$i;$j++) {$str.="*";}

echo "$i -> " . time() . " $str n";

exit();

// 子程序程序程式碼段_End

}

}

if ($bWaitFlag)

{

for($i = 0; $i < $intNum; $i++) {

pcntl_waitpid($pids[$i], $status, WUNTRACED);

echo "wait $i -> " . time() . "n";

}

}

echo ("Endn");

?>

3. 利用WEB SERVER, PHP不支援多執行緒, APACHE可是支援的, 呵呵.

假設我們現在執行的是這個文件. 但是我在程式中又請求WEB伺服器執行另一個

那麼這兩個文件將是同時執行的.(程式碼同上)

當然啦,也可以把需要多執行緒處理的部分交給JAVA去處理, 然後在PHP裡呼叫, 哈哈.

<?php

system('java ');

?>