实例分析：例2：使用管道流完成线程之间的通讯。 (二)

static class ThreadZ extends Thread {
DataOutputStream dos = null;

DataInputStream dis = null;

public ThreadZ(OutputStream os, InputStream is) {
dos = new DataOutputStream(os);
dis = new DataInputStream(is);
}

public void run() {
while (true) {
try {
double d = dis.readDouble();
dos.writeDouble(d);
} catch (Exception e) {
e.printStackTrace();
}
}
}
};

static class ThreadQ extends Thread {
DataInputStream dis = null;

public ThreadQ(InputStream is) {
dis = new DataInputStream(is);
}

public void run() {
while (true) {
try {
double d = dis.readDouble();
System.out.println(d);
} catch (Exception e) {
e.printStackTrace();
}
}
}
};
}

编译运行

javac TestPipeStream.java

java TestPipeStream