// 字符输入流
class CharThreadReader extends Thread {
private PipedReader pipedReader;
public CharThreadReader(PipedReader pipedReader) {
this.pipedReader = pipedReader;
}
@Override
public void run() {
try {
char[] c = new char[] { 1024 * 3 };
int readLength = pipedReader.read(c);
while (readLength != -1) {
System.out.print(new String(c, 0, readLength));
readLength = pipedReader.read(c);
}
pipedReader.close();
} catch (IOException e) {
e.printStackTrace();
}
}
}