知识大全 Java 中利用管道实现线程间的通讯

Posted 2022-07-18 知

篇首语：早晨要撒你种，晚上也不要歇你手。本文由小常识网(cha138.com)小编为大家整理，主要介绍了知识大全 Java 中利用管道实现线程间的通讯相关的知识，希望对你有一定的参考价值。

Java 中利用管道实现线程间的通讯 以下文字资料是由(全榜网网www.cha138.com)小编为大家搜集整理后发布的内容，让我们赶快一起来看一下吧！

　　在Java 语言中提供了各种各样的输入输出流（stream）使我们能够很方便的对数据进行操作其中管道（pipe）流是一种特殊的流用于在不同线程（threads）间直接传送数据一个线程发送数据到输出管道另一个线程从输入管道中读数据通过使用管道实现不同线程间的通讯无需求助于类似临时文件之类的东西本文在简要介绍管道的基本概念后将以一个具体的实例pipeapp加以详细说明　　．管道的创建与使用　　Java提供了两个特殊的专门的类专门用于处理管道它们就是pipedinputstream类和pipeoutputstream类　　Pipedinputstream代表了数据在管道中的输出端也就是线程向管道读数据的一端 pipeoutputstream代表了数据在管道中的输入端也就是线程向管道写数据的一端这两个类一起使用可以提供数据的管道流　　为了创建一个管道流我们必须首先创建一个pipeoutstream对象然后创建pipeinputstream对象实例如下　　pipeout= new pipedyoutstream();　　pipein= new pipedputsteam(pipepout);　　一旦创建了一个管道后就可以象操作文件一样对管道进行数据的读写　　．演示程序 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()返回的输入流开始　　datainputstream yfileln= new datainputstream(inputstream);　　程序创建一个新的管道　　pipedoutstream pipeout = new pipedoutputstream();　　　　pipedinputstream pipeln = new pipedinputsream(pipeout ); 　　该线程通过这个新的管道发出修改后的数据（输入流pipeln ）给主程序　　源程序如下　　//　　//pipeapp Java pipeapp的主应用程序　　//　　import Java io *　　class pipeapp　　　　public static void main(string[] args)　　　　pipeapp pipeapp=new pipeapp();　　try　　　　fileinputstream xfile =new fileinputstream( input txt );　　inputstream ylnpipe = pipeapp changetoy(xfileln);　　inputstream zlnpipe=pipeapp changetoz(ylnpipe);　　system out println();　　system out println( here are the results );　　system out pringln();　　datainputstream inputstream = nes datainputstream(zlnpipe);　　string str = inputstream readline();　　while (str!=null)　　　　system out println(str);　　str=inputstream readline();　　　　inputstream close();　　　　catch(exception e)　　　　system out println(e tostring());　　　　　　public inputstream changetoy(inputstream inputstream)　　　　try　　　　datainputstream pipeout = new datainputsteam(inputstream);　　pipedoutstream pipeout = new pipedoutputstream();　　pipedlnsteam pipeln = new pipedlnputstream(pipeout);　　printstream printstream = new printstream(pipeout);　　ythread ythread = new ythread(xfileln printstream);　　ythread start();　　return pipeln;　　　　catch(exeption e)　　　　system out println(x tostring());　　　　return null;　　　　public inputstream changetoz(inputstream inputsteam)　　　　try　　　　datainputstream yfileln = new datainputstream(inputstream);　　pipeoutputstream pipeln = new pipedinputstream(pipeout );　　printrstream printstream = new printsteam(pipeout );　　zthread zthread = new zthread(yfileln printstream );　　zthread start();　　return pipeln ;　　　　catch(exception e)　　　　system out println(e tostring());　　　　return null;　　　　　　Ythread类和Zthread类　　由于ythread类与zthread类基本一样在此仅以ythread为例加以说明　　Ythread的构造器接收两个参数输入的文件和第一个管道的输出端构造器存储这两个参数作为类的数据成员　　　Ythread(datainputstream xfileln pringstream printstream)　　　　　　this xfileln = xfileln;　　this printstream = printstream;　　　　　　线程通过run()方法来处理数据首先读取一行数据确保xstring不为空的情况下循环执行　　string xstring = xfileln readline();　　每读一行数据完成一次转换　　string ystring = xstring replace( x y );　　然后将修改后的数据输出到管道的输出端　　prinstream prinrln(ystring);　　为了确保所有缓冲区的数据完全进入管道的输出端　　pringstram flush();　　循环完成后线程关闭管道输出流　　　pringstram close();　　ythread类的源程序如下　　//ythread Java　　//　　import Java io *;　　class ythread exteads thread　　　　datainputstream xfileln;　　pringstream printstream;　　ythread(datainputstream xfileln pringstream printstream)　　　　this xfileln = xfileln;　　this printstream = printstream;　　　　public void run()　　　　try　　　　string xstring = xfileln readline();　　while(xstring!=null)　　　　string ystring= xstring replace( x y );　　printstream pringln(ystring);　　printstream flush();　　xstring= xfileln readline();　　　　printstream close();　　　　catchioexception e　　　　system out println(e tostring());　　　　　　　　pipeapp应用程序使用microsoft visual j++ 编译 cha138/Article/program/Java/gj/201311/27508