この記事の例では、PHP マルチスレッド プログラミングにおけるパイプライン通信の使用法について説明します。参考のためにみんなで共有してください。具体的な分析は次のとおりです:
1 つのスレッドが個人の英雄主義である場合、複数のスレッドは集団主義です。あなたはもはや孤独なレンジャーではなく、指揮者です。
パイプライン通信:
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 |
クラスパイプ { パブリック $fifoPath; プライベート $w_pipe; プライベート $r_pipe;
/** * パイプラインを自動的に作成します * * @param string $name パイプ名 * @param int $mode パイプ権限。デフォルトでは、すべてのユーザー グループが読み取りと書き込みが可能です */ 関数 __construct($name = 'pipe', $mode = 0666) { $fifoPath = "/tmp/$name." . if (!file_exists($fifoPath)) {if (!posix_mkfifo($fifoPath, $mode)) { error("新しいパイプ ($name) の作成エラー。"); false を返す; } } 他 { error( "パイプ ($name) が終了しました。"); false を返す; } $this->fifoPath = $fifoPath; } ////////////////////////////////////////////// // // 写管道関数数开始 ////////////////////////////////////////////// // 関数open_write() { $this->w_pipe = fopen($this->fifoPath, 'w'); if ($this->w_pipe == NULL) { error("書き込みエラーのためパイプ {$this->fifoPath} を開きます。"); false を返す; } true を返す; }
関数書き込み($data) { return fwrite($this->w_pipe, $data); }
関数 write_all($data) { $w_pipe = fopen($this->fifoPath, 'w'); fwrite($w_pipe, $data); fclose($w_pipe); }
関数 close_write() { return fclose($this->w_pipe); } ////////////////////////////////////////////// //////// /// 读管道相关関数数开始 ////////////////////////////////////////////// /////// 関数open_read() { $this->r_pipe = fopen($this->fifoPath, 'r'); if ($this->r_pipe == NULL) { error("読み取りエラーのためパイプ {$this->fifoPath} を開きます。"); false を返す; } true を返す; } 関数読み取り($byte = 1024) { return fread($this->r_pipe, $byte); } 関数 read_all() { $r_pipe = fopen($this->fifoPath, 'r'); $data = ''; while (!feof($r_pipe)) { //エコー「1 Kn を読んでください」; $data .= fread($r_pipe, 1024); } fclose($r_pipe); $data を返す; } 関数 close_read() { return fclose($this->r_pipe); } /** * パイプを削除します * * @return ブール値は成功です */ 関数rm_pipe() { return unlink($this->fifoPath); } } ?> /* このタイプがあると、単一のパイプライン通信を実現できます。 |
http://www.bkjia.com/PHPjc/963970.html