管道流实现线程间的通信

旧城等待， 2023-06-13 09:43 15阅读 0赞

## 管道流（PipedInputStream、PipedOutputStream）继承自inputStream，一般用户线程间通信，不过一般不用它。。 ##

。。  
**测试案例**

## 发送方线程创建 ##

class SendThread implements Runnable{ 
        private PipedOutputStream outputStream = new PipedOutputStream();
        @Override
        public void run() { 
            try { 
                outputStream.write("管道对接成功！！".getBytes());
            } catch (IOException e) { 
                e.printStackTrace();
            }
        }
        public PipedOutputStream getOutputStream() { 
            return outputStream;
        }
        public void setOutputStream(PipedOutputStream outputStream) { 
            this.outputStream = outputStream;
        }
    }

## 接收方线程创建 ##

class RecieveThread implements Runnable{ 
        private PipedInputStream inputStream = new PipedInputStream();
        @Override
        public void run() { 
            byte[] data = new byte[1024];
            try { 
                int len = inputStream.read(data);
                System.out.println("对接情况："+new String(data,0,len));
            } catch (IOException e) { 
                e.printStackTrace();
            }
        }
    
        public PipedInputStream getInputStream() { 
            return inputStream;
        }
    
        public void setInputStream(PipedInputStream inputStream) { 
            this.inputStream = inputStream;
        }
    }

## 测试 ##

public class GuandaoTest { 
        public static void main(String[] args) { 
            SendThread sendThread = new SendThread();
            RecieveThread recieveThread = new RecieveThread();
            PipedOutputStream outputStream = sendThread.getOutputStream();
            try { 
                outputStream.connect(recieveThread.getInputStream());
                new Thread(sendThread).start();
                new Thread(recieveThread).start();
            } catch (IOException e) { 
                e.printStackTrace();
            }
        }
    }

## 分析 ##

在接受方有输入的管道流，发送方有输出的管道流，在客户端获取输出流，与其输入流进行对接，相当于管道接通，这时输入流就收到了输出流的信息。