zoukankan      html  css  js  c++  java
  • Java线程间通信:使用管道

    管道输入/输出流和普通的文件输入/输出流或者网络输入/输出流不同之处在于,它主要用于线程之间的数据传输,而传输的媒介为内存。

    管道输入/输出流主要包括了如下4种具体实现:PipedOutputStream、PipedInputStream、PipedReader和PipedWriter,前两种面向字节,而后两种面向字符。

    package gj.concurrent.sync;
    
    import java.io.IOException;
    import java.io.PipedReader;
    import java.io.PipedWriter;
    
    /**
     * Author: areful
     */
    public class PipedSync {
        private static class Writer implements Runnable {
            private PipedWriter out;
    
            private Writer(PipedWriter writer) {
                out = writer;
            }
    
            @Override
            public void run() {
                int receive;
                try {
                    while ((receive = System.in.read()) != -1) {
                        out.write(receive);
                    }
                } catch (Exception ignored) {
                } finally {
                    try {
                        out.close();
                    } catch (IOException ignored) {
                    }
                }
            }
        }
    
        private static class Printer implements Runnable {
            private PipedReader in;
    
            private Printer(PipedReader in) {
                this.in = in;
            }
    
            public void run() {
                int receive;
                try {
                    while ((receive = in.read()) != -1) {
                        System.out.print((char) receive);
                    }
                } catch (IOException ignored) {
                }
            }
        }
    
        public static void main(String[] args) throws Exception {
            PipedWriter out = new PipedWriter();
            PipedReader in = new PipedReader();
            out.connect(in);
    
            Thread printThread = new Thread(new Printer(in), "PrintThread");
            printThread.start();
    
            Thread writeThread = new Thread(new Writer(out), "WriteThread");
            writeThread.start();
        }
    }
    

      

  • 相关阅读:
    VB程序破解常用函数
    去VB程序NAG窗口方法-4C法
    error LNK2005: _DllMain@12 已经在 XXXX.obj 中定义
    汇编中的test和cmp指令
    OD保存修改后的数据到EXE
    C++ 异常捕获 try 和 __try的区别
    CListCtrl选中行
    WindowsAPI解析IAT地址
    Usaco 4.3.1 Buy Low, Buy Lower 逢低吸纳详细解题报告
    全国青少年信息学奥林匹克分区联赛(N)竞赛大纲
  • 原文地址:https://www.cnblogs.com/areful/p/10396181.html
Copyright © 2011-2022 走看看