频道栏目
首页 > 程序开发 > 软件开发 > Java > 正文
java管道流的读写操作,用于两个线程之间的通信
2011-08-12 14:47:56      个评论      
收藏   我要投稿

/* java 管道流的读写操作 用于两个线程之间  
 PipedOutputStream    PipedInputStream  连接起来就是一个管道   
 管道输出流可以向管道写入数据   管道输入流可以从管道读取数据   
 这种Decorator 装饰 的设计模式 大大增强了java流的功能
 可以在构造流的时候连接 管道输入输出流 也可以通过connect函数连接

*/
import java.io.*  ;
class  PipeTest
{
 public  static   void main(String []args)  throws Exception
 {
     PipedInputStream pis=new PipedInputStream() ;   //构造管道输入流
     PipedOutputStream pos=new  PipedOutputStream(pis); //构造输出流并且连接输入流形成管道
     new Procedure(pos).start() ;  //线程启动
     new Consumer(pis).start();  //线程启动
   
 }
}

class  Procedure  extends Thread   //线程1管道 输出流
{
   private  PipedOutputStream  pos ;
   Procedure(PipedOutputStream  pos)
   {
         this.pos=pos ;
   }
    public  void run()
   {
         try
         {
            pos.write("hello! welcome you!".getBytes());  //向管道写入 数据
         }
         catch(Exception e)
         {         
           e.printStackTrace();
         }
   }
 
 
}

class  Consumer  extends  Thread
{
 private  PipedInputStream pis ;
 Consumer(PipedInputStream pis)
 {
      this.pis=pis ;
 }
 public   void  run()
 {
       try
       { 
          
           byte []buf=new byte[100] ;
           int len=pis.read(buf,0,100);            //从管道读取数据
           System.out.println(new String(buf,0,len)); 
        }
       catch(Exception e)
       {
           e.printStackTrace() ;
       }
    
 
 }
 
 
 
 
 
 
 
 
}

点击复制链接 与好友分享!回本站首页
上一篇:Java Quartz自动调度
下一篇:编写java代码的几点技巧
相关文章
图文推荐
点击排行

关于我们 | 联系我们 | 广告服务 | 投资合作 | 版权申明 | 在线帮助 | 网站地图 | 作品发布 | Vip技术培训 | 举报中心

版权所有: 红黑联盟--致力于做实用的IT技术学习网站