Use the PipedInputStream class and the PipedOutputStream class to learn about communication between pipe streams.

[[433836]]

Hello everyone, I am a Java expert.

Preface

Use PipedInputStream and PipedOutputStream in the application to create communication between pipes. A PipedInputStream instantiation object and a PipedOutputStream instantiation object are connected to generate a communication pipe. PipedInputStream is used to read written data from the pipe, and PipedOutputStream is used to write data to the pipe. Use PipedInputStream and PipedOutputStream for communication between threads. Use PipedInputStream and PipedOutputStream to learn about communication between pipe streams. Next, let's learn together!

1. PipedInputStream Class

1. PipedInputStream class Piped input stream, which can be connected to a piped output stream. The piped input stream provides the bytes of all data to be written to the piped output stream.

2. PipedInputStream class construction method:

(1) public PipedInputStream(): Creates a piped input stream object, which is not yet connected.

(2) public PipedInputStream(PipedOutputStream out): Creates a piped input stream, which is connected to the piped output stream specified by the parameter out. As shown below:

 PipedInputStream pis=new PipedInputStream();

3. The PipedInputStream class methods are:

(1) int read(): reads the next byte of data.

(2) int read(byte []b, int off, int len): reads len bytes of data into a byte array. The off parameter indicates the offset and len indicates the length of the read data.

(3)void receive(int b): receives one byte of data.

(4) void connect(PipedOutputStream src): indicates that the piped input stream is connected to the piped output stream src

(5) int available(): indicates that there is nothing to prevent reading bytes from the input stream.

(6)void close(): means closing the stream.

2. PipedOutputStream Class

1. The PipedOutputStream class is a piped output stream, which can be used to write data to the pipe.

2. PipedOutputStream class construction method:

(1) public PipedOutputStream(): Creates a piped output stream object, which is not yet connected.

(2) public PipedOutputStream(PipedInputStream in): Creates a piped output stream, which is connected to the piped input stream specified by the parameter in. As shown below:

 PipedOutputStream pos=new PipedOutputStream();

3. The PipedOutputStream class methods are:

(1) void close(): means closing the stream.

(2) void connect(PipedInputStream snk): indicates that the piped output stream is connected to the piped input stream.

(3) void flush(): Flushes the output stream and forces any buffered output bytes to be written out.

(4)void write(int b): Writes the specified byte to the pipe output stream.

(5) void write(byte[] b, int off, int len): Writes len bytes of the specified byte array starting at offset off to the piped output stream.

3. Use PipedInputStream and PipedOutputStream to learn about communication between pipeline streams

1. Code implementation:

 import java.io.*; 
 
 public class P22 {
 public   static void main(String[] args) throws Exception {
 //Create a PipedInputStream object
 final PipedInputStream in =new PipedInputStream();
 final PipedOutputStream out =new PipedOutputStream();
 //Connect the two classes
 in . connect ( out );
 new Thread(new Runnable(){
 public void run(){
            BufferedReader br=new BufferedReader(new InputStreamReader(System. in ));
 //Read data from the keyboard and write it to the pipe stream
            PrintStream ps=new PrintStream( out );
 System. out .print(Thread.currentThread().getName()+ "Please enter content:" );
 try {
                ps.println(br.readLine());
            } catch (IOException e) {
                e.printStackTrace();
 }
 }
 }, "thread sending data" ).start();
 new Thread(new Runnable(){
 public void run(){
            BufferedReader br=new BufferedReader(new InputStreamReader( in ));
 try {
 System. out .println(Thread.currentThread().getName()+ "Received content: " +br.readLine());
            } catch (IOException e) {
                e.printStackTrace();
 }
 }
 }, "thread receiving data" ).start();
 }
 }

The result of the operation is shown in the figure below:

In the above code, a PipedInputStream object and a PipedOutputStream object are used to connect to generate a communication pipe. Two threads are written, one thread is used for the keyboard input data pipe output stream, and the other thread is used to read the written data in the pipe. These two classes are used to realize the communication between threads.

IV. Conclusion

This article mainly introduces the PipedInputStream class, the PipedOutputStream class, and how to use the PipedInputStream class and the PipedOutputStream class to learn about communication between pipeline streams. The PipedInputStream class is a pipeline input stream that can be connected to a pipeline output stream. The pipeline input stream provides the bytes of all data to be written to the pipeline output stream. PipedInputStream introduces its construction method and methods. The PipedOutputStream class is a pipeline output stream that can be used to write data to a pipeline. PipedOutputStream introduces its construction method and methods. Use the PipedInputStream class and the PipedOutputStream class to learn about communication between pipeline streams. I hope that this article will be helpful to you!

This article is reprinted from the WeChat public account "Java Advanced Learning Exchange", which can be followed through the following QR code. To reprint this article, please contact the Java Advanced Learning Exchange public account.