任务间使用管道进行输入/输出

怼烎@ 2022-06-15 09:43 152阅读 0赞

通过PipedWriter类小姑娘管道中写数据

PipedReader类允许不同任务从同一管道中读取数据，如果当前没有数据就阻塞，等待数据的到来。

并且PiPedReader 类与普通I/O之间有重要的差异，可以被中断。

class Sender implements Runnable{
        private Random rand=new Random(47);
        private PipedWriter out=new PipedWriter();
        public PipedWriter getOut() {
            return out;
        }
        @Override
        public void run() {
            try {
                while(true){
                    for(char c='A';c<='z';c++){
                        out.write(c);
                        TimeUnit.MILLISECONDS.sleep(rand.nextInt(500));
                    }
                }
            } catch (IOException e) {
                System.out.println(e+" Sender write excetption");
            } catch (InterruptedException e) {
                System.out.println(e+" Sender sleep interrupted");
            }
        }
    }
    class Receiver implements Runnable{
        private PipedReader in;
        public Receiver(Sender sender) throws IOException{
            in=new PipedReader(sender.getOut());
        }
    
        @Override
        public void run() {
            try {
                while(true){
                    System.out.println("Read: "+(char)in.read()+" ");
                }
            } catch (IOException e) {
                System.out.println(e+" Receiver read exception");
            }
        }
    }
    public class PipedIO {
        public static void main(String[] args)throws Exception{
            Sender sender=new Sender();
            Receiver receiver=new Receiver(sender);
            ExecutorService exec= Executors.newCachedThreadPool();
            exec.execute(sender);
            exec.execute(receiver);
            TimeUnit.SECONDS.sleep(4);
            exec.shutdownNow();
        }
    }

Read: A  
Read: B  
Read: C  
Read: D  
Read: E  
Read: F  
Read: G  
Read: H  
Read: I  
Read: J  
Read: K  
Read: L  
Read: M  
java.lang.InterruptedException: sleep interrupted Sender sleep interrupted  
java.io.InterruptedIOException Receiver read exception