1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65
| import java.io.BufferedInputStream;
import java.io.BufferedReader;
import java.io.ByteArrayInputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.io.PipedInputStream;
import java.io.PipedOutputStream;
import fr.laposte.disf.indus.util.Logger;
public class Test {
public static void main(String[] args) throws IOException {
Test test = new Test();
test.process();
}
public void process() throws IOException {
Thread readThread = new PipedInputThread();
Thread writeThread = new PipedOutputThread();
readThread.start();
writeThread.start();
System.out.println("Fin du main");
}
class PipedInputThread extends Thread {
public void run() {
BufferedReader br = null;
br = new BufferedReader(new InputStreamReader(System.in));
String line="";
try {
while (!(line = br.readLine()).equals("exit")) {
System.out.println("The automatic input :" + line);
}
} catch (IOException e) {
// TODO Bloc catch auto-généré
e.printStackTrace();
}
}
}
class PipedOutputThread extends Thread {
public void run() {
try {
//Il faut router le out vers System.in
// mais comment ?
OutputStream out =System.out;
Thread.sleep(1000);
out.write("echo1".getBytes());
System.out.println("Fin du start de PipedOutputThread ");
} catch (Exception e) {
e.printStackTrace();
}
}
}
} |