java的IO 管道流

Java code:
import java.io.IOException;
import java.io.PipedInputStream;
import java.io.PipedOutputStream;

public class TestPip {

public static void main(String[] args) {
PipedInputStream pis = new PipedInputStream();
PipedOutputStream pos = new PipedOutputStream();
try {
pis.connect(pos);//连接
} catch (IOException e) {
e.printStackTrace();

}
new Sender(pos).start();
new Ser(pis).start();
}
}

class Sender extends Thread{
private PipedOutputStream pos;
public Sender(PipedOutputStream pos){
this.pos = pos;
}
public void run(){
byte buf[] = new byte[1024];
try {
pos.write("Hello word".getBytes());
pos.close();
} catch (IOException e) {
e.printStackTrace();
}
}
}
class Ser extends Thread{
private PipedInputStream pis;
public Ser(PipedInputStream pis){
this.pis = pis;
}
public void run(){
byte buf[] = new byte[1024];
try {
int len = pis.read(buf);
System.out.println(new String(buf,0,len)+"\n How do you");
} catch (IOException e) {
e.printStackTrace();
}
}
}


Java code

---

Code highlighting produc