萬盛學電腦網

 萬盛學電腦網 >> 網絡編程 >> php編程 >> PHP多線程編程之管道通信實例分析

PHP多線程編程之管道通信實例分析

 這篇文章主要介紹了PHP多線程編程之管道通信,實例分析了管道通信的原理與相關使用技巧,具有一定參考借鑒價值,需要的朋友可以參考下

   

本文實例講述了PHP多線程編程之管道通信用法。分享給大家供大家參考。具體分析如下:

一個線程如果是個人英雄主義,那麼多線程就是集體主義,你不再是一個獨行俠,而是一個指揮家。

管道通信:
1. 管道可以認為是一個隊列,不同的線程都可以往裡面寫東西,也都可以從裡面讀東西。寫就是
在隊列末尾添加,讀就是在隊頭刪除。

2. 管道一般有大小,默認一般是4K,也就是內容超過4K了,你就只能讀,不能往裡面寫了。

3. 默認情況下,管道寫入以後,就會被阻止,直到讀取他的程序讀取把數據讀完。而讀取線程也會被阻止,
直到有進程向管道寫入數據。當然,你可以改變這樣的默認屬性,用stream_set_block 函數,設置成非阻斷模式。

下面是我分裝的一個管道的類(這個類命名有問題,沒有統一,沒有時間改成統一的了,我一般先寫測試代碼,最後分裝,所以命名上可能不統一):

? 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 <?php class Pipe { public $fifoPath; private $w_pipe; private $r_pipe;   /** * 自動創建一個管道 * * @param string $name 管道名字 * @param int $mode 管道的權限,默認任何用戶組可以讀寫 */ 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; } /////////////////////////////////////////////////// // 寫管道函數開始 /////////////////////////////////////////////////// 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); } ///////////////////////////////////////////////////////// /// 讀管道相關函數開始 //////////////////////////////////////////////////////// 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 Kn"; $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); } } ?> /* 有了這個類,就可以實現簡單的管道通信了。*/

希望本文所述對大家的php程序設計有所幫助。

copyright © 萬盛學電腦網 all rights reserved