用PipedInputStream/PipedOutputStream进行线程间通讯会有延迟？
请看下面的代码：
import java.io.IOException;import java.io.InputStream;import java.io.OutputStream;import java.io.PipedInputStream;import java.io.PipedOutputStream;import java.io.PrintStream;public class Expriment{ public Expriment() { } /** * Launch the application. */ public static void main(String[] args) { try { PipedInputStream pis = new PipedInputStream(1024); PipedOutputStream pos = new PipedOutputStream(pis); ReadThread rt = new ReadThread(pis); WriteThread wt = new WriteThread(pos); wt.start(); rt.start(); Thread.sleep(10000); wt.interrupt(); rt.interrupt(); } catch (IOException e) { e.printStackTrace(); } catch (InterruptedException e) { e.printStackTrace(); } }}class WriteThread extends Thread{ public WriteThread(OutputStream outputStream) { this.outputStream = outputStream; } @Override public void run() { int count = 0; do { count++; try { outputStream.write(new String(count + ": Hello, world ! I'm a write thread.\n").getBytes()); sleep(250); } catch (IOException e) { e.printStackTrace(); break; } catch (InterruptedException e) { e.printStackTrace(); break; } } while(!interrupted()); } private OutputStream outputStream;}class ReadThread extends Thread{ public ReadThread(InputStream inputStream) { this.inputStream = inputStream; } @Override public void run() { byte[] buffer = new byte[1024]; do { try { int readCount = inputStream.read(buffer, 0, 16); if (readCount > 0) { System.out.print(new String(buffer, 0, readCount)); } } catch (IOException e) { e.printStackTrace(); break; } } while(!interrupted()); } private InputStream inputStream;}