您好,登錄后才能下訂單哦!
這篇文章主要介紹了PHP多線程編程之管道通信的示例分析,具有一定借鑒價(jià)值,感興趣的朋友可以參考下,希望大家閱讀完這篇文章之后大有收獲,下面讓小編帶著大家一起了解一下。
具體分析如下:
一個(gè)線程如果是個(gè)人英雄主義,那么多線程就是集體主義,你不再是一個(gè)獨(dú)行俠,而是一個(gè)指揮家。
管道通信:
1. 管道可以認(rèn)為是一個(gè)隊(duì)列,不同的線程都可以往里面寫東西,也都可以從里面讀東西。寫就是
在隊(duì)列末尾添加,讀就是在隊(duì)頭刪除。
2. 管道一般有大小,默認(rèn)一般是4K,也就是內(nèi)容超過4K了,你就只能讀,不能往里面寫了。
3. 默認(rèn)情況下,管道寫入以后,就會(huì)被阻止,直到讀取他的程序讀取把數(shù)據(jù)讀完。而讀取線程也會(huì)被阻止,
直到有進(jìn)程向管道寫入數(shù)據(jù)。當(dāng)然,你可以改變這樣的默認(rèn)屬性,用stream_set_block 函數(shù),設(shè)置成非阻斷模式。
下面是我分裝的一個(gè)管道的類(這個(gè)類命名有問題,沒有統(tǒng)一,沒有時(shí)間改成統(tǒng)一的了,我一般先寫測試代碼,最后分裝,所以命名上可能不統(tǒng)一):
<?php class Pipe { public $fifoPath; private $w_pipe; private $r_pipe; /** * 自動(dòng)創(chuàng)建一個(gè)管道 * * @param string $name 管道名字 * @param int $mode 管道的權(quán)限,默認(rèn)任何用戶組可以讀寫 */ function __construct($name = 'pipe', $mode = 0666) { $fifoPath = "/tmp/$name." . posix_getpid(); if (!file_exists($fifoPath)) { if (!posix_mkfifo($fifoPath, $mode)) { error("create new pipe ($name) error."); return false; } } else { error( "pipe ($name) has exit."); return false; } $this->fifoPath = $fifoPath; } /////////////////////////////////////////////////// // 寫管道函數(shù)開始 /////////////////////////////////////////////////// function open_write() { $this->w_pipe = fopen($this->fifoPath, 'w'); if ($this->w_pipe == NULL) { error("open pipe {$this->fifoPath} for write error."); return false; } return true; } function write($data) { return fwrite($this->w_pipe, $data); } function write_all($data) { $w_pipe = fopen($this->fifoPath, 'w'); fwrite($w_pipe, $data); fclose($w_pipe); } function close_write() { return fclose($this->w_pipe); } ///////////////////////////////////////////////////////// /// 讀管道相關(guān)函數(shù)開始 //////////////////////////////////////////////////////// function open_read() { $this->r_pipe = fopen($this->fifoPath, 'r'); if ($this->r_pipe == NULL) { error("open pipe {$this->fifoPath} for read error."); return false; } return true; } function read($byte = 1024) { return fread($this->r_pipe, $byte); } function read_all() { $r_pipe = fopen($this->fifoPath, 'r'); $data = ''; while (!feof($r_pipe)) { //echo "read one K\n"; $data .= fread($r_pipe, 1024); } fclose($r_pipe); return $data; } function close_read() { return fclose($this->r_pipe); } /** * 刪除管道 * * @return boolean is success */ function rm_pipe() { return unlink($this->fifoPath); } } ?> /* 有了這個(gè)類,就可以實(shí)現(xiàn)簡單的管道通信了。*/
感謝你能夠認(rèn)真閱讀完這篇文章,希望小編分享的“PHP多線程編程之管道通信的示例分析”這篇文章對大家有幫助,同時(shí)也希望大家多多支持億速云,關(guān)注億速云行業(yè)資訊頻道,更多相關(guān)知識等著你來學(xué)習(xí)!
免責(zé)聲明:本站發(fā)布的內(nèi)容(圖片、視頻和文字)以原創(chuàng)、轉(zhuǎn)載和分享為主,文章觀點(diǎn)不代表本網(wǎng)站立場,如果涉及侵權(quán)請聯(lián)系站長郵箱:is@yisu.com進(jìn)行舉報(bào),并提供相關(guān)證據(jù),一經(jīng)查實(shí),將立刻刪除涉嫌侵權(quán)內(nèi)容。