PipedInputStream & PipedOutputStream 小实例

Love The Way You Lie 2022-08-07 03:41 131阅读 0赞

在一个Java app 进程中  内部产生两个线程。一个线程产生数据 ，另一个线程从产生数据的线程读取过来。

package com.test.PipedInputStream\_PipedOutputStreamTest;

import java.io.PipedInputStream;  
import java.io.PipedOutputStream;  
  
public class Demo  
\{  
    public static void main(String\[\] args) throws Exception  
    \{  
        PipedInputStream pin = new PipedInputStream();  
        PipedOutputStream pout = new PipedOutputStream();  
        pin.connect(pout); // 输入流与输出流连接  
  
        ReadThread readTh = new ReadThread(pin);  
        WriteThread writeTh = new WriteThread(pout);  
        new Thread(readTh).start();  
        new Thread(writeTh).start();  
    \}  
  
    public static void sop(Object obj) // 打印  
    \{  
        System.out.println(obj);  
    \}  
\}  
  
class ReadThread implements Runnable  
\{  
    private PipedInputStream pin;  
  
    ReadThread(PipedInputStream pin) //  
    \{  
        this.pin = pin;  
    \}  
  
    public void run() // 由于必须要覆盖run方法,所以这里不能抛,只能try  
    \{  
        try  
        \{  
            sop("R:读取前没有数据,阻塞中...等待数据传过来再输出到控制台...");  
            byte\[\] buf = new byte\[1024\];  
            int len = pin.read(buf); // read阻塞  
            sop("R:读取数据成功,阻塞解除...");  
  
            String s = new String(buf, 0, len);  
            sop(s); // 将读取的数据流用字符串以字符串打印出来  
            pin.close();  
        \}  
        catch (Exception e)  
        \{  
            throw new RuntimeException("R:管道读取流失败!");  
        \}  
    \}  
  
    public static void sop(Object obj) // 打印  
    \{  
        System.out.println(obj);  
    \}  
\}  
  
class WriteThread implements Runnable  
\{  
    private PipedOutputStream pout;  
  
    WriteThread(PipedOutputStream pout)  
    \{  
        this.pout = pout;  
    \}  
  
    public void run()  
    \{  
        try  
        \{  
            sop("W:开始将数据写入:但等个5秒让我们观察...");  
            Thread.sleep(5000); // 释放cpu执行权5秒  
            pout.write("W: writePiped 数据...".getBytes()); // 管道输出流  
            pout.close();  
        \}  
        catch (Exception e)  
        \{  
            throw new RuntimeException("W:WriteThread写入失败...");  
        \}  
    \}  
  
    public static void sop(Object obj) // 打印  
    \{  
        System.out.println(obj);  
    \}  
\}