java学习笔记:管道流PipedInputStream和PipedOutputStream

 

/*  
管道流:
PipedInputStream
void connect(PipedOutputStream src) 
使此管道输入流连接到管道输出流 src

PipedOutputStream
void connect(PipedInputStream snk)  

在JDK我们看到PipedInputStream中有管道缓冲区,用来接收数据

管道流内部在实现时还有大量的对同步数据的处理
管道输出流和管道输入流执行时不能互相阻塞,所以一般要开启独立线程分别执行
顺便复习了多线程操作

[示例]:管道流
*/
import java.io.*;

class Demo            
{
  public static void main(String[] args)  throws Exception
  {
    PipedInputStream pin = new PipedInputStream();
    PipedOutputStream pout = new PipedOutputStream();
    pin.connect(pout);  //输入流与输出流连接
    
    ReadThread readTh   = new ReadThread(pin);
    WriteThread writeTh = new WriteThread(pout);
    new Thread(readTh).start();
    new Thread(writeTh).start();
  }
  
  public static void sop(Object obj) //打印
  {
    System.out.println(obj);
  }
}

class ReadThread implements Runnable
{
  private PipedInputStream pin;
  ReadThread(PipedInputStream pin)   //
  {
    this.pin=pin;
  }
  
  public void run() //由于必须要覆盖run方法,所以这里不能抛,只能try
  {
    try
    {
      sop("R:读取前没有数据,阻塞中...等待数据传过来再输出到控制台...");
      byte[] buf = new byte[1024];
      int len = pin.read(buf);  //read阻塞
      sop("R:读取数据成功,阻塞解除...");
      
      String s= new String(buf,0,len);
      sop(s);    //将读取的数据流用字符串以字符串打印出来
      pin.close();     
    }
    catch(Exception e)
    {
      throw new RuntimeException("R:管道读取流失败!");
    }   
  }
  
  public static void sop(Object obj) //打印
  {
    System.out.println(obj);
  }
}

class WriteThread implements Runnable
{
  private PipedOutputStream pout;
  WriteThread(PipedOutputStream pout)
  {
    this.pout=  pout;
  }
  
  public void run()
  {
    try
    {
      sop("W:开始将数据写入:但等个5秒让我们观察...");
      Thread.sleep(5000);  //释放cpu执行权5秒
      pout.write("W: writePiped 数据...".getBytes());  //管道输出流
      pout.close();
    }
    catch(Exception e)
    {
      throw new RuntimeException("W:WriteThread写入失败...");
    }
  }
  
  public static void sop(Object obj) //打印
  {
    System.out.println(obj);
  }
}

编译成功，class文件运行结果:

R:读取前没有数据,阻塞中...等待数据传过来再输出到控制台...
W:开始将数据写入:但等个5秒让我们观察...
R:读取数据成功,阻塞解除...
W: writePiped 数据...

评论

1 楼 blackproof 2012-12-14  

楼主可以用Callable