码迷,mamicode.com
首页 > 其他好文 > 详细

PipedOutputStream&PipedInputStream---管道流

时间:2016-10-01 15:01:14      阅读:146      评论:0      收藏:0      [点我收藏+]

标签:

管道流通常与多线程技术相结合

import java.io.IOException;
import java.io.PipedInputStream;
import java.io.PipedOutputStream;

public class PipedStreamDemo {

    public static void main(String[] args) throws IOException {
        
        //管道流和多线程技术相结合
        PipedInputStream pis =new PipedInputStream();
        PipedOutputStream pos = new PipedOutputStream();
        
        //将两个流连接上。
        pis.connect(pos);
        new Thread(new Input(pis)).start();
        new Thread(new Output(pos)).start();
        
    }

}
//定义输入任务
class Input implements Runnable{
    
    private PipedInputStream pis;
    
    public Input(PipedInputStream pis) {
        super();
        this.pis = pis;
    }
    @Override
    public void run() {
        
        byte[] buf = new byte[1024];
        int len;
        try {
            len = pis.read(buf);
            String str = new String(buf,0,len);
            System.out.println(str);
            pis.close();
        } catch (IOException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
        
    }
}

//定义输出任务
class Output implements Runnable{
    PipedOutputStream pos;
    
    
    public Output(PipedOutputStream pos) {
        super();
        this.pos = pos;
    }


    @Override
    public void run() {
        
        //通过写方法完成
        try {
            pos.write("嘿,管道来了".getBytes());
            
            pos.close();
        } catch (IOException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
        
    }
    
    
}

 

PipedOutputStream&PipedInputStream---管道流

标签:

原文地址:http://www.cnblogs.com/qjlbky/p/5925751.html

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!