import ohos.hiviewdfx.HiLog;
import ohos.hiviewdfx.HiLogLabel;
import ohos.hiviewdfx.HiLogConst;

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

public class PipedStreamExample {
    private static final HiLogLabel LABEL = new HiLogLabel(HiLogConst.DEBUG, 0x00201, "PipedStreamExample");

    public static void main(String[] args) {
        try {
            // 创建PipedInputStream和PipedOutputStream
            PipedInputStream pipedInputStream = new PipedInputStream();
            PipedOutputStream pipedOutputStream = new PipedOutputStream();

            // 将输入流和输出流关联起来
            pipedInputStream.connect(pipedOutputStream);

            // 创建两个线程，一个用于写入数据，一个用于读取数据
            Thread writerThread = new Thread(() -> {
                try {
                    // 向输出流写入数据
                    String dataToWrite = "Hello, HarmonyOS!";
                    pipedOutputStream.write(dataToWrite.getBytes());
                    pipedOutputStream.close(); // 关闭输出流
                } catch (IOException e) {
                    HiLog.error(LABEL, "写入数据时发生错误：{}", e.getMessage());
                }
            });

            Thread readerThread = new Thread(() -> {
                try {
                    // 从输入流读取数据
                    byte[] buffer = new byte[1024];
                    int bytesRead = pipedInputStream.read(buffer);
                    String dataRead = new String(buffer, 0, bytesRead);
                    HiLog.info(LABEL, "从管道中读取到的数据：{}", dataRead);
                } catch (IOException e) {
                    HiLog.error(LABEL, "读取数据时发生错误：{}", e.getMessage());
                }
            });

            // 启动线程
            writerThread.start();
            readerThread.start();

            // 等待线程结束
            writerThread.join();
            readerThread.join();

        } catch (IOException | InterruptedException e) {
            HiLog.error(LABEL, "发生错误：{}", e.getMessage());
        }
    }
}