Subversion Repositories openrisc

// 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());

      }

  }

}