// Create a process and pipe data through it. waitFor() the process // in a different thread than the one that created it. import java.io.BufferedReader; import java.io.InputStream; import java.io.InputStreamReader; import java.io.OutputStream; import java.io.PrintStream; public class Process_3 implements Runnable { Process p; public void run() { try { Runtime r = Runtime.getRuntime(); String[] a = { "sed", "-e", "s/Hello/Goodbye/" }; synchronized (this) { p = r.exec(a); this.notifyAll(); } OutputStream os = p.getOutputStream(); PrintStream ps = new PrintStream(os); ps.println("Hello World"); ps.close(); } catch (Exception ex) { System.out.println(ex.toString()); System.exit(1); } } public static void main(String[] args) { try { Process_3 p3 = new Process_3(); Thread t = new Thread(p3); t.start(); synchronized (p3) { while (p3.p == null) p3.wait(); } InputStream is = p3.p.getInputStream(); InputStreamReader isr = new InputStreamReader(is); BufferedReader br = new BufferedReader(isr); String result = br.readLine(); if (! "Goodbye World".equals(result)) { System.out.println("bad 1"); return; } result = br.readLine(); if (result != null) { System.out.println("bad 2"); return; } int c = p3.p.waitFor(); System.out.println(c == 0 ? "ok" : "bad 3"); } catch (Exception ex) { System.out.println(ex.toString()); } } }