管道的创建与使用
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()
返回的输入流开始：
datainputstream yfileln= new datainputstream(inputstream);
程序创建一个新的管道：
pipedoutstream pipeout2 = new pipedoutputstream();
pipedinputstream pipeln2 = new pipedinputsream(pipeout2);
该线程通过这个新的管道发出修改后的数据（输入流
pipeln2
）给主程序。
|
收藏
淘帖
踩
