???? 管道輸入流從一個管道輸出流中讀取數據。通常由一個線程向管道輸出流寫數據，由另一個線程從管道輸入流中讀取數據，兩個線程可以用管道來通信。當線程A執行管道輸入流的的read()方法時，如果暫時還沒有數據，這個線程就會被阻塞，只有當線程B向管道輸出流寫了新的數據后，線程A才會恢復運行。 下面我們來演示一個例子?
Sender類?
? Receiver類?
?? 線程Sender向管道輸出流中寫字節，線程Receiver 從管道輸入流中讀取字節。線程Sender輸出的字節序列與線程 Receiver讀入的字節序列相同。
Sender類?
Java代碼??
- package ?xiaohang.com;??
- ??
- import ?java.io.PipedOutputStream;??
- ??
- /**?向管道輸出流寫數據的線程?*/ ??
- class ?Sender? extends ?Thread?{??
- ???? private ?PipedOutputStream?out?=? new ?PipedOutputStream();??
- ??
- ???? public ?PipedOutputStream?getPipedOutputStream()?{??
- ???????? return ?out;??
- ????}??
- ??
- ???? @Override ??
- ???? public ? void ?run()?{??
- ???????? try ?{??
- ???????????? for ?( int ?i?=?- 127 ;?i?<? 128 ;?i++)?{??
- ????????????????out.write(i);??
- ???????????????? //?暫停當前正在執行的線程執行其它線程 ??
- ????????????????yield();??
- ????????????}??
- ???????????? //?關閉此管道輸出流并釋放與此流有關的所有系統資源?此流可能無法再用于寫入字節。 ??
- ????????????out.close();??
- ????????}? catch ?(Exception?e)?{??
- ???????????? throw ? new ?RuntimeException(e);??
- ????????}??
- ????}??
- }??
? Receiver類?
Java代碼??
- package ?xiaohang.com;??
- ??
- import ?java.io.IOException;??
- import ?java.io.PipedInputStream;??
- ??
- /**?從管道輸入流讀取數據的線程?*/ ??
- public ? class ?Receiver? extends ?Thread?{??
- ???? private ?PipedInputStream?in;??
- ??
- ???? public ?Receiver(Sender?sender)? throws ?IOException?{??
- ???????? //?使此管道輸入流連接到管道輸出流?PipedOutputStream對象?如果此對象已經連接到其他某個管道輸出流，則拋出 ??
- ???????? //?IOException ??
- ????????in?=? new ?PipedInputStream(sender.getPipedOutputStream());??
- ????}??
- ??
- ???? @Override ??
- ???? public ? void ?run()?{??
- ???????? try ?{??
- ???????????? int ?data;??
- ???????????? while ?((data?=?in.read())?!=?- 1 )??
- ????????????????System.out.println(data);??
- ????????????in.close();??
- ????????}? catch ?(Exception?e)?{??
- ???????????? throw ? new ?RuntimeException(e);??
- ????????}??
- ????}??
- ??
- ???? public ? static ? void ?main(String?args[])? throws ?Exception?{??
- ????????Sender?sender?=? new ?Sender();??
- ????????Receiver?receiver?=? new ?Receiver(sender);??
- ????????sender.start();??
- ????????receiver.start();??
- ????}??
- }??
?? 線程Sender向管道輸出流中寫字節，線程Receiver 從管道輸入流中讀取字節。線程Sender輸出的字節序列與線程 Receiver讀入的字節序列相同。
更多文章、技術交流、商務合作、聯系博主
微信掃碼或搜索：z360901061
微信掃一掃加我為好友
QQ號聯系： 360901061
您的支持是博主寫作最大的動力，如果您喜歡我的文章，感覺我的文章對您有幫助，請用微信掃描下面二維碼支持博主2元、5元、10元、20元等您想捐的金額吧，狠狠點擊下面給點支持吧，站長非常感激您！手機微信長按不能支付解決辦法：請將微信支付二維碼保存到相冊，切換到微信，然后點擊微信右上角掃一掃功能，選擇支付二維碼完成支付。
【本文對您有幫助就好】元
