Java 中利用管道实现线程间的通讯

　2008-01-05 20:04:47　来源：WEB开发网　闂傚倸鍊搁崐鎼佸磹妞嬪孩顐芥慨姗嗗厳缂傛氨鎲稿鍫罕闂備礁婀遍搹搴ㄥ窗閺嶎偆涓嶆い鏍仦閻撱儵鏌ｉ弴鐐测偓鍦偓姘炬嫹

闂傚倸鍊搁崐鎼佸磹妞嬪海鐭嗗〒姘ｅ亾妤犵偛顦甸弫鎾绘偐閹绘帞鈧參姊哄Ч鍥х仼闁诲繑鑹鹃悾鐑藉蓟閵夛妇鍘甸梺瑙勵問閸犳牠銆傛總鍛婄厱閹艰揪绱曟牎闂侀潧娲ょ€氫即鐛幒妤€绠ｆ繝闈涘暙娴滈箖鏌ｉ姀鈶跺湱澹曟繝姘厵闁绘劦鍓氶悘杈ㄤ繆閹绘帞澧涚紒缁樼洴瀹曞崬螖閸愬啠鍓濈换娑樼暆婵犱胶鏁栫紓浣介哺閹瑰洤鐣烽幒鎴僵闁瑰吀鐒﹂悗鎼佹⒒娴ｇ儤鍤€闁搞倖鐗犻獮蹇涙晸閿燂拷

濠电姷鏁告慨鐑藉极閸涘﹥鍙忔い鎾卞灩缁狀垶鏌涢幇闈涙灈鐎瑰憡绻冮妵鍕箻鐎靛摜鐣奸梺纭咁潐濞茬喎顫忕紒妯肩懝闁逞屽墮宀ｈ儻顦查悡銈夋煏閸繃鍋繛宸簻鎯熼梺瀹犳〃閼冲爼宕濋敃鈧—鍐Χ閸℃鐟愰梺鐓庡暱閻栧ジ宕烘繝鍥у嵆闁靛骏绱曢崢顏堟⒑閹肩偛鍔楅柡鍛⊕缁傛帟顦寸紒杈ㄥ笚濞煎繘鍩℃担閿嬵潟闂備浇妗ㄩ悞锕傚箲閸ヮ剙鏋侀柟鍓х帛閺呮悂鏌ㄩ悤鍌涘闂傚倸鍊搁崐鎼佸磹妞嬪孩顐芥慨姗嗗厳缂傛氨鎲稿鍫罕闂備礁婀遍搹搴ㄥ窗閺嶎偆涓嶆い鏍仦閻撱儵鏌ｉ弴鐐测偓鍦偓姘炬嫹　　闂傚倸鍊搁崐鎼佸磹閻戣姤鍤勯柤鍝ユ暩娴犳氨绱撻崒娆掑厡缂侇噮鍨堕妴鍐川閺夋垹鍘洪悗骞垮劚椤︻垶宕￠幎鑺ョ厪闊洦娲栨牎闂佽瀵掗崜鐔奉潖閾忓湱纾兼俊顖氭惈椤矂姊洪崷顓涙嫛闁稿妫濋幆鈧い蹇撴祩濡嫰姊洪崫鍕拱婵炲弶岣块幑銏犫攽婵犲嫮鏉搁梺鍝勬川婵兘鎮伴妷鈺傗拻濞达絽鎼敮璺侯熆閻熷府鏀荤紒鍌氱Т楗即宕煎锝呬壕闁哄啫鐗嗙粈鍐┿亜韫囧海顦﹀ù婊堢畺閺屻劌鈹戦崱娑扁偓妤€顭胯閸犳牠婀侀梺缁樕戦悷銉р偓姘煎枤缁粯銈ｉ崘鈺冨幈濡炪倖鍔戦崐鏇㈠几鎼淬劍鐓熼煫鍥ь儏閸旀粓鏌曢崶褍顏€殿喗娼欒灒闁告繂瀚濠碉紕鍋戦崐鎴﹀垂濞差亝鍋￠柍鍝勬噹缁犳牠鏌嶉埡浣告殲闁稿海鍠栭弻鏇㈠炊瑜嶇花濠氭煙閸戙倖瀚�

核心提示：在java 语言中，提供了各种各样的输入输出流（stream）,使我们能够很方便的对数据进行操作，Java 中利用管道实现线程间的通讯，其中，管道（pipe）流是一种非凡的流，该线程是ythread类的一个对象，他传递两个参数：输入文件（xfileln）和输出管道（调用printstream）ythread ythre

　　在java 语言中，提供了各种各样的输入输出流（stream）,使我们能够很方便的对数据进行操作，其中，管道（pipe）流是一种非凡的流，用于在不同线程（threads）间直接传送数据。一个线程发送数据到输出管道，另一个线程从输入管道中读数据。通过使用管道，实现不同线程间的通讯。无需求助于类似临时文件之类的东西。本文在简要介绍管道的基本概念后，将以一个具体的实例pipeapp加以具体说明。

1．管道的创建与使用

　　Java提供了两个非凡的专门的类专门用于处理管道，它们就是pipedinputstream类和pipeoutputstream类。

　　Pipedinputstream代表了数据在管道中的输出端，也就是线程向管道读数据的一端；pipeoutputstream代表了数据在管道中的输入端，也就是线程向管道写数据的一端，这两个类一起使用可以提供数据的管道流。

　　为了创建一个管道流，我们必须首先创建一个pipeoutstream对象，然后，创建pipeinputstream对象，实例如下：

　　pipeout= new pipedyoutstream();
　　pipein= new pipedputsteam(pipepout);

　　一旦创建了一个管道后，就可以象操作文件一样对管道进行数据的读写。

2．演示程序： pipeapp

　　应用程序由三个程序组成：主线程（pipeapp.Java）及由主线程启动的两个二级线程（ythread.Java和zthread.Java）,它们使用管道来处理数据。程序从一个内容为一行一行"x"字母的"input.txt"文件中读取数据，使用管道传输数据，第一次是利用线程ythread将数据"x"转换为"y"，最后利用线程zthread将"y"转换为"z",之后，程序在屏幕上显示修改后的数据。

　　主线程（pipeapp.Java）

　　在main()方法中，程序首先创建一个应用对象：pipeapp pipeapp=new pipeapp();

由于程序中流操作都需要使用IOException异常处理，所以设置了一个try块。在try中，为了从源文件中读取数据，程序为"input.txt"文件创建了一个输入流Xfileln,:

　　fileinputstream xfileln= new fileinputstream("input.txt");

　　新的输入流传递给changetoy()方法，让线程ythread能读取该文件：

　　inputstream ylnpipe =pipeapp.changetoy(xfileln);

　　changetoy()方法创建将输入数据"x"改变到"y"的线程ythread,并返回该线程的输入管道：

　　inputstream zlnpipe = pipeapp.changetoz(ylnpipe);

　　changetoz()方法启动将数据从"y"改变到"z"的线程zehread,主程序将使用从changetoz()返回的输入管道。得到以修改的数据。

　　然后，程序将管道输入流定位到datainputstream对象，使程序能够使用readline()方法读取数据：
　　datainputstream inputstream = new datainputstream(zlnpiepe);

　　创建了输入流以后，程序就可以以行一行的读取数据病显示在屏幕上。

　　String str= inputstream.readline();
　　While(str!=null)
　　{
　　　　system.out.PRintln(str);
　　　　str=inputstream.readline();
　　}

显示完成之后，程序关闭输入流：

　　inputstream.close();
　　changetoy()方法

changetoy()方法首先通过传递一个参数inputstream给datainputstream对象来定位资源的输入流，使程序能使用readline()方法从流中读取数据：

　　datainputstream xfileln =new datainutstream(inputstream)；

　　然后，changetoy()创建输出管道和输入管道：

　　pipeoutstream pipeout = new pipeoutputstream();
　　pipeinputstream pipeln = new pipedinputsteam(pipeout);

为了能够使用println()方法输出修改的后的文本行到管道，程序将输出管道定位到printstream对象：

　　printstream printstream = new printstream(pipeout);

　　现在，程序可以创建将数据从x改变到y的线程，该线程是ythread类的一个对象，他传递两个参数：输入文件（xfileln）和输出管道（调用printstream）

　　ythread ythread =new thread(xfileln,printstream);

　　之后，程序启动线程：

　　changetoz（）方法

　　changetoz()方法与changetoy()方法很相似，他从changetoy()返回的输入流开始：