管道输入流从一个管道输出流中读取数据。通常由一个线程向管道输出流写数据,由另一个线程从管道输入流中读取数据,两个线程可以用管道来通信。当线程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读入的字节序列相同。
分享到:
相关推荐
在IT行业中,输入流(InputStream)和输出流(OutputStream)是Java.IO库中的核心概念,它们用于处理数据的读取和写入。标题提到的"一个输入流写到多个输出流"是一个常见的需求,特别是在并发编程和数据传输场景中。...
PipedInputStream是一个输入流,它接收从PipedOutputStream写入的数据。而PipedOutputStream则是一个输出流,它将数据写入到与之连接的PipedInputStream中。两者通过建立连接形成管道,实现数据的双向流动。 创建...
1. 管道输出流(PipedOutputStream)与管道输入流(PipedInputStream) PipedOutputStream是OutputStream的直接子类,负责向管道中写入字节数据;而PipedInputStream是InputStream的直接子类,负责从管道中读取字节...
PipedInputStream和PipedOutputStream允许在不同的线程间传递数据,实现数据的管道传输。DataInputStream和DataOutputStream提供了一种方式来读写基本的Java数据类型,如int、float和double。 在提供的`FileOut....
在实际开发中,`PipedOutputStream`和`PipedInputStream`也可以用来实现输出流和输入流之间的连接,它们之间可以通过管道进行数据传输,但这种方式相对复杂,适用于更高级的同步和异步操作。 总结,将`OutputStream...
这种设计导致了一个问题:当输出流写入20个字节后,输入流只能读取10个字节,这会导致剩余的10个字节仍然留在缓冲区中,直到下一次读取时才能被读取。 ### 总结 通过上述分析可以看出,管道流是一种非常有用的工具...
PipedInputStream是一个输入流,它可以从与之相连的PipedOutputStream获取数据。PipedOutputStream则是输出流,用于写入数据到PipedInputStream。通过将System.out和System.err的打印流替换为PipedOutputStream,...
通过调用`PipedOutputStream`的`connect`方法,将输出流与输入流关联起来,从而建立管道连接。 3. 数据传输 `Send`线程通过`write`方法将字符串转换为字节数组并写入到`PipedOutputStream`,而`Receive`线程通过`...
- `PipedInputStream`:管道输入流,用于线程间的通信。 - `SequenceInputStream`:将多个输入流组合成一个输入流。 - **OutputStream**:代表数据目的的输出流。 - `ByteArrayOutputStream`:将数据输出到内存中...
- 输入流(Input Stream):用于从数据源读取数据,数据源可以是文件、网络连接或其他数据产生器。 - 输出流(Output Stream):用于向目的地写入数据,目的地可能是文件、显示器或其他数据接收器。 2. **流的...
|--PipedOutputStream/:可以将管道输出流连接到管道输入流来创建通信管道。 | 用方法connect(PipedInputStream snk) 将此管道输出流连接到接收者。 同样使用多线程技术,避免死锁。 |--ByteArrayOutputStream/:...
管道流允许线程间的直接通信,数据可以从一个线程的输出流直接传递到另一个线程的输入流。 9. 标准流(System.in, System.out, System.err): 标准输入流、标准输出流和标准错误输出流是Java应用程序与用户的默认...
在Java中,输入和输出操作通过流(Stream)进行,这些流分为字节流和字符流两大类,每类又包含输入流和输出流。 **字节流** 字节流处理的是8位的字节数据,它主要用于处理二进制数据,如图像、音频文件等。Java的...
PipedInputStream 管道输入流应该连接到管道输出流;管道输入流提供要写入管道输出流的所有数据字节。 PipedOutputStream 可以将管道输出流连接到管道输入流来创建通信管道。 PipedReader 传送的字符输入流。 ...
流可以分为四类:字节流(Byte Stream)和字符流(Character Stream),以及输入流(Input Stream)和输出流(Output Stream)。字节流处理单个字节的数据,而字符流处理Unicode字符,如UTF-8编码。 1. 字节流 - ...
管道流(PipedInputStream/PipedOutputStream/PipedReader/PipedWriter)则允许在不同的线程之间建立数据通道,实现数据的同步传输。 过滤流(FilterInputStream/FilterOutputStream/FilterReader/FilterWriter)是...
两者需要通过构造函数相互关联,以便数据可以从输出流流向输入流。这个过程通常涉及在两个线程之间进行,一个线程负责写入,另一个线程负责读取,确保数据的同步传输。 在“Pipe”这个压缩包中,可能包含了一个...
输入流主要用于读取数据,它是所有字节输入流的基类,位于`java.io`包下。几个重要的子类包括: 1. `FileInputStream`: 用于从文件中读取数据。 2. `BufferedInputStream`: 提供缓冲功能,提高读取效率。 3. `...
- **InputStream** 和 **OutputStream** 是所有字节输入流和输出流的基类,用于处理二进制数据,如图像、音频等。 - **FileInputStream** 和 **FileOutputStream** 用于文件的读写操作。 - **BufferedInputStream...
- InputStream:所有输入流的基类,用于读取原始字节。它定义了基本的读取方法,如read()用于获取单个字节。 - ByteArrayInputStream:从字节数组创建的输入流,可以从内存中读取数据。 - ...