线程间通过管道流进行通信

管道流主要用于在不同线程间直接传送数据

一个线程发送数据到输出管道，另一个线程从输入管道中读取数据，进而实现不同线程间的通信

字节管道流

-------------------------------------------------------------字节流-------------------------------------------------------------

package com.qf.test12.pipe.Stream;

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

/**
 * @author qf
 * @create 2018-09-20 9:26
 */
public class WriteData {
    public void testWrite(PipedOutputStream out){
        try {
            System.out.println("write:");
            for (int i = 0; i < 50; i++) {
                String str = " "+(i+1);
                out.write(str.getBytes());
                System.out.print(str);
            }
            System.out.println();
            out.close();
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}

package com.qf.test12.pipe.Stream;

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

/**
 * @author qf
 * @create 2018-09-20 9:38
 */
public class ReadData {
    public void testRead(PipedInputStream in){
        try {
            System.out.println("read:");
            byte[] bytes = new byte[1024];
            int readLen = in.read(bytes);
            while (readLen != -1){
                String str = new String(bytes,0,readLen);
                System.out.print(str);
                readLen = in.read(bytes);
            }
            System.out.println();
            in.close();
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}

-------------------------------------------------------------线程类-------------------------------------------------------------

package com.qf.test12.pipe.thread;

import com.qf.test12.pipe.Stream.WriteData;

import java.io.PipedOutputStream;

/**
 * @author qf
 * @create 2018-09-20 9:44
 */
public class ThreadW extends Thread {
    private WriteData writeData;
    private PipedOutputStream out;

    public ThreadW(WriteData writeData, PipedOutputStream out) {
        this.writeData = writeData;
        this.out = out;
    }

    @Override
    public void run() {
        writeData.testWrite(out);
    }
}

package com.qf.test12.pipe.thread;

import com.qf.test12.pipe.Stream.ReadData;

import java.io.PipedInputStream;

/**
 * @author qf
 * @create 2018-09-20 9:45
 */
public class ThreadR extends Thread {
    private ReadData readData;
    private PipedInputStream in;

    public ThreadR(ReadData readData, PipedInputStream in) {
        this.readData = readData;
        this.in = in;
    }

    @Override
    public void run() {
        readData.testRead(in);
    }
}

-------------------------------------------------------------测试类-------------------------------------------------------------

package com.qf.test12;

import com.qf.test12.pipe.Stream.ReadData;
import com.qf.test12.pipe.Stream.WriteData;
import com.qf.test12.pipe.thread.ThreadR;
import com.qf.test12.pipe.thread.ThreadW;

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

/**
 * @author qf
 * @create 2018-09-20 9:47
 */
public class RunStream {
    public static void main(String[] args) {
        try {
            WriteData write = new WriteData();
            ReadData read = new ReadData();

            PipedInputStream in = new PipedInputStream();
            PipedOutputStream out = new PipedOutputStream();

            out.connect(in);// 或者in.connect(out);作用是使得两个Stream流之间产生通信连接，才能对数据进行输入输出

            ThreadR threadR = new ThreadR(read,in);
            threadR.start();

            Thread.sleep(2000);

            ThreadW threadW = new ThreadW(write,out);
            threadW.start();

        } catch (IOException e) {
            e.printStackTrace();
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }
}

------------------------------------------------------------打印输出-----------------------------------------------------------

read:
//休眠2000ms
write:
 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50
 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50

线程threadR先被启动，但是因为管道流中并没有数据，所以线程会阻塞在in.read(bytes)这里，直到有数据被写入，才会继续向下运行

字符管道流

将写入/读取数据的方式改为字符流的形式

-------------------------------------------------------------字符流-------------------------------------------------------------

package com.qf.test12.pipe.ReaderWriter;

import java.io.IOException;
import java.io.PipedReader;

/**
 * @author qf
 * @create 2018-09-20 9:38
 */
public class ReadData {
    public void testRead(PipedReader in){
        try {
            System.out.println("read:");
            char[] chars = new char[1024];
            int readLen = in.read(chars);
            while (readLen != -1){
                String str = new String(chars,0,readLen);
                System.out.print(str);
                readLen = in.read(chars);
            }
            System.out.println();
            in.close();
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}

package com.qf.test12.pipe.ReaderWriter;

import java.io.IOException;
import java.io.PipedWriter;

/**
 * @author qf
 * @create 2018-09-20 9:26
 */
public class WriteData {
    public void testWrite(PipedWriter out){
        try {
            System.out.println("write:");
            for (int i = 0; i < 50; i++) {
                String str = " "+(i+1);
                out.write(str.toCharArray());
                System.out.print(str);
            }
            System.out.println();
            out.close();
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}

-------------------------------------------------------------线程类-------------------------------------------------------------

package com.qf.test12.pipe.ReaderWriter.thread;


import com.qf.test12.pipe.ReaderWriter.ReadData;

import java.io.PipedReader;


/**
 * @author qf
 * @create 2018-09-20 9:45
 */
public class ThreadR extends Thread {
    private ReadData readData;
    private PipedReader in;

    public ThreadR(ReadData readData, PipedReader in) {
        this.readData = readData;
        this.in = in;
    }

    @Override
    public void run() {
        readData.testRead(in);
    }
}

package com.qf.test12.pipe.ReaderWriter.thread;


import com.qf.test12.pipe.ReaderWriter.WriteData;

import java.io.PipedWriter;

/**
 * @author qf
 * @create 2018-09-20 9:44
 */
public class ThreadW extends Thread {
    private WriteData writeData;
    private PipedWriter out;

    public ThreadW(WriteData writeData, PipedWriter out) {
        this.writeData = writeData;
        this.out = out;
    }

    @Override
    public void run() {
        writeData.testWrite(out);
    }
}

-------------------------------------------------------------测试类-------------------------------------------------------------

package com.qf.test12;

import com.qf.test12.pipe.ReaderWriter.ReadData;
import com.qf.test12.pipe.ReaderWriter.WriteData;
import com.qf.test12.pipe.ReaderWriter.thread.ThreadR;
import com.qf.test12.pipe.ReaderWriter.thread.ThreadW;


import java.io.*;

/**
 * @author qf
 * @create 2018-09-20 9:47
 */
public class RunReaderWriter {
    public static void main(String[] args) {
        try {
            WriteData write = new WriteData();
            ReadData read = new ReadData();

            PipedWriter out = new PipedWriter();
            PipedReader in = new PipedReader();

            out.connect(in);// 或者in.connect(out);作用是使得两个Stream流之间产生通信连接，才能对数据进行输入输出

            ThreadR threadR = new ThreadR(read,in);
            threadR.start();

            Thread.sleep(2000);

            ThreadW threadW = new ThreadW(write,out);
            threadW.start();

        } catch (IOException e) {
            e.printStackTrace();
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }
}

------------------------------------------------------------打印输出-----------------------------------------------------------

read:
//睡眠2000ms
write:
 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50
 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50