管道输入流从一个管道输出流中读取数据。通常由一个线程向管道输出流写数据,由另一个线程从管道输入流中读取数据,两个线程可以用管道来通信。当线程A执行管道输入流的的read()方法时,如果暂时还没有数据,这个线程就会被阻塞,只有当线程B向管道输出流写了新的数据后,线程A才会恢复运行。 下面我们来演示一个例子
Sender类
- package xiaohang.com;
-
- import java.io.PipedOutputStream;
-
-
- class Sender extends Thread {
- private PipedOutputStream out = new PipedOutputStream();
-
- public PipedOutputStream getPipedOutputStream() {
- return out;
- }
-
- @Override
- public void run() {
- try {
- for (int i = -127; i < 128; i++) {
- out.write(i);
-
- yield();
- }
-
- out.close();
- } catch (Exception e) {
- throw new RuntimeException(e);
- }
- }
- }
Receiver类
- package xiaohang.com;
-
- import java.io.IOException;
- import java.io.PipedInputStream;
-
-
- public class Receiver extends Thread {
- private PipedInputStream in;
-
- public Receiver(Sender sender) throws IOException {
-
-
- in = new PipedInputStream(sender.getPipedOutputStream());
- }
-
- @Override
- public void run() {
- try {
- int data;
- while ((data = in.read()) != -1)
- System.out.println(data);
- in.close();
- } catch (Exception e) {
- throw new RuntimeException(e);
- }
- }
-
- public static void main(String args[]) throws Exception {
- Sender sender = new Sender();
- Receiver receiver = new Receiver(sender);
- sender.start();
- receiver.start();
- }
- }
线程Sender向管道输出流中写字节,线程Receiver 从管道输入流中读取字节。线程Sender输出的字节序列与线程 Receiver读入的字节序列相同。
分享到:
相关推荐
针对java中的管道流的应用的解析,包括PipedInputStream和PipedOutputStream。
|--PipedOutputStream/:可以将管道输出流连接到管道输入流来创建通信管道。 | 用方法connect(PipedInputStream snk) 将此管道输出流连接到接收者。 同样使用多线程技术,避免死锁。 |--ByteArrayOutputStream/:...
PipedInputStream 管道输入流应该连接到管道输出流;管道输入流提供要写入管道输出流的所有数据字节。 PipedOutputStream 可以将管道输出流连接到管道输入流来创建通信管道。 PipedReader 传送的字符输入流。 ...
java管道流 Listing 1:用管道流截取控制台输出】 PipedInputStream pipedIS = new PipedInputStream(); PipedOutputStream pipedOS = new PipedOutputStream(); try { pipedOS.connect(pipedIS); } catch...
Java中的PipedWriter、PipedReader类管道的读写依赖于PipedOutputStream、PipedInputStream两个管道输入输出类,这里我们将来举例讲解Java中Piped管道输入输出流的线程通信控制:
主要为大家详细介绍了管道PipedInputStream和PipedOutputStream,具有一定的参考价值,感兴趣的小伙伴们可以参考一下
PipedInputStream 是从与其它线程共用的管道中读取数据,与Piped 相关的知识后续单独介绍。 ObjectInputStream 和所有FilterInputStream 的子类都是装饰流(装饰器模式的主角)。 2.输出字节流OutputStream IO 中...
4)SequenceInputStream:这个类可以将几个输入流串联在一起合并为一个输入流,构造函数有: SequenceInputStream(Enumeration e)枚举类型e中包含了若干个要被串联的输入流 SequenceInputStream(InputStream s1, ...
PipedInputStream和PipedOutputStream_动力节点Java学院整理
javaIO流原代码,刚刚开始学习java的同志们可以看看.有问题留言.
2、常用21个IO流:FileWriter、FileReader、CharArrayReader、CharArrayWriter、CharSequence、OutputStreamWriter、FileOutputStream、InputStreamReader、PrintWriter、BufferedReader、InputStream、...
包含了Java里面大部分的 流类的小实例Propertity FileReader FileWriter FileInputStream PipedInputStream..........
4) PipedInputStream:实现了pipe的概念,主要在线程中使用 5) SequenceInputStream:把多个InputStream合并为一个InputStream 2) Out stream 1) ByteArrayOutputStream:把信息存入内存中的一个缓冲区中 2) ...
4) PipedInputStream:实现了pipe的概念,主要在线程中使用 5) SequenceInputStream:把多个InputStream合并为一个InputStream 2) Out stream 1) ByteArrayOutputStream:把信息存入内存中的一个缓冲区中 2) ...
此存储库用于演示java.io.PipedInputStream (Oracle Java 实现,存在于 1.7 和 1.8)中的错误。 这是一个最小的工作示例,用于证明PipedInputStream包含一个错误,该错误导致相应的PipedOutputStream等待最多...
4) PipedInputStream:实现了pipe的概念,主要在线程中使用 5) SequenceInputStream:把多个InputStream合并为一个InputStream 2. Out stream 1) ByteArrayOutputStream:把信息存入内存中的一个缓冲区中 2) ...
集合I/O多线程NIOjava基础知识点整理jvmspring 相关MYSQL分布式存储检索java源码学习集合Linkedlist详解Vector详解Stack详解Map构架HashMap详解HashMap...OPipedOutputStream and PipedInputStream 详解BufferInputStream...