黑马程序员技术交流社区
标题: 管道流 [打印本页]
作者: 草上飞 时间: 2012-11-4 21:56
标题: 管道流
管道流
PipedInputStream
流管道输入流应该连接到管道输出流；管道输入流提供要写入管道输出流的所有数据字。通常，数据由某个线程从 PipedInputStream 对象读取，并由其他线程将其写入到相应的 PipedOutputStream。不建议对这两个对象尝试使用单个线程，因为这样可能死锁线程。管道输入流包含一个缓冲区，可在缓冲区限定的范围内将读操作和写操作分离开。如果向连接管道输出流提供数据字节的线程不再存在，则认为该管道已损坏。
PipedOutputStream
可以将管道输出流连接到管道输入流来创建通信管道。管道输出流是管道的发送端。通常，数据由某个线程写入 PipedOutputStream 对象，并由其他线程从连接的 PipedInputStream 读取。不建议对这两个对象尝试使用单个线程，因为这样可能会造成该线程死锁。如果某个线程正从连接的管道输入流中读取数据字节，但该线程不再处于活动状态，则该管道被视为处于 毁坏 状态。
import java.io.*;
class Pipedstremdemo
{
public static void main(String[] args) throws Exception
{
PipedInputStream pis=new PipedInputStream();
PipedOutputStream pos=new PipedOutputStream();
pos.connect(pis);//管道输出流和管道输入流可也随意匹配链接
Read r=new Read(pis);
Write w=new Write(pos);
new Thread(r).start();//创建管道读取线程
new Thread(w).start();//创建管道输出线程
}
}
class Read implements Runnable
{
private PipedInputStream pis;
Read(PipedInputStream pis)
{
this.pis=pis;
}
public void run()
{
try
{
byte[] by=new byte[1024*4];
int len=pis.read(by);
String str=new String(by,0,len);
System.out.println(str);//打印读取到得数据
pis.close();
}
catch (Exception e)
{
throw new RuntimeException("管道读取失败");
}
}
}
class Write implements Runnable
{
private PipedOutputStream pos;
Write(PipedOutputStream pos)
{
this.pos=pos;
}
public void run()
{
try
{
//Thread.sleep(3000);
pos.write("dfdfdfd".getBytes());//将string编码为byte序列
pos.close();
}
catch (Exception e)
{
throw new RuntimeException("管道输出失败");
}
}
}
作者: 陈军 时间: 2012-11-5 10:13
这是视频么？ {:soso_e136:}
作者: 草上飞 时间: 2012-11-5 12:26
你不懂啊？
| 欢迎光临 黑马程序员技术交流社区 (http://bbs.itheima.com/) |
黑马程序员IT技术论坛 X3.2 |