???? 管道輸入流從一個(gè)管道輸出流中讀取數(shù)據(jù)。通常由一個(gè)線程向管道輸出流寫(xiě)數(shù)據(jù)，由另一個(gè)線程從管道輸入流中讀取數(shù)據(jù)，兩個(gè)線程可以用管道來(lái)通信。當(dāng)線程A執(zhí)行管道輸入流的的read()方法時(shí)，如果暫時(shí)還沒(méi)有數(shù)據(jù)，這個(gè)線程就會(huì)被阻塞，只有當(dāng)線程B向管道輸出流寫(xiě)了新的數(shù)據(jù)后，線程A才會(huì)恢復(fù)運(yùn)行。 下面我們來(lái)演示一個(gè)例子?
Sender類?
? Receiver類?
?? 線程Sender向管道輸出流中寫(xiě)字節(jié)，線程Receiver 從管道輸入流中讀取字節(jié)。線程Sender輸出的字節(jié)序列與線程 Receiver讀入的字節(jié)序列相同。
Sender類?
Java代碼??
- package ?xiaohang.com;??
- ??
- import ?java.io.PipedOutputStream;??
- ??
- /**?向管道輸出流寫(xiě)數(shù)據(jù)的線程?*/ ??
- 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);??
- ???????????????? //?暫停當(dāng)前正在執(zhí)行的線程執(zhí)行其它線程 ??
- ????????????????yield();??
- ????????????}??
- ???????????? //?關(guān)閉此管道輸出流并釋放與此流有關(guān)的所有系統(tǒng)資源?此流可能無(wú)法再用于寫(xiě)入字節(jié)。 ??
- ????????????out.close();??
- ????????}? catch ?(Exception?e)?{??
- ???????????? throw ? new ?RuntimeException(e);??
- ????????}??
- ????}??
- }??
? Receiver類?
Java代碼??
- package ?xiaohang.com;??
- ??
- import ?java.io.IOException;??
- import ?java.io.PipedInputStream;??
- ??
- /**?從管道輸入流讀取數(shù)據(jù)的線程?*/ ??
- public ? class ?Receiver? extends ?Thread?{??
- ???? private ?PipedInputStream?in;??
- ??
- ???? public ?Receiver(Sender?sender)? throws ?IOException?{??
- ???????? //?使此管道輸入流連接到管道輸出流?PipedOutputStream對(duì)象?如果此對(duì)象已經(jīng)連接到其他某個(gè)管道輸出流，則拋出 ??
- ???????? //?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向管道輸出流中寫(xiě)字節(jié)，線程Receiver 從管道輸入流中讀取字節(jié)。線程Sender輸出的字節(jié)序列與線程 Receiver讀入的字節(jié)序列相同。
更多文章、技術(shù)交流、商務(wù)合作、聯(lián)系博主
微信掃碼或搜索：z360901061
微信掃一掃加我為好友
QQ號(hào)聯(lián)系： 360901061
您的支持是博主寫(xiě)作最大的動(dòng)力，如果您喜歡我的文章，感覺(jué)我的文章對(duì)您有幫助，請(qǐng)用微信掃描下面二維碼支持博主2元、5元、10元、20元等您想捐的金額吧，狠狠點(diǎn)擊下面給點(diǎn)支持吧，站長(zhǎng)非常感激您！手機(jī)微信長(zhǎng)按不能支付解決辦法：請(qǐng)將微信支付二維碼保存到相冊(cè)，切換到微信，然后點(diǎn)擊微信右上角掃一掃功能，選擇支付二維碼完成支付。
【本文對(duì)您有幫助就好】元
