Performances with gcj

import java.io.BufferedReader;
import java.io.DataOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.io.PipedInputStream;
import java.io.PipedOutputStream;

public class PipeTest {
	public static void main(String args[]) {
		System.out.println("START");
		try { /* set up pipes */
			PipedOutputStream pout1 = new PipedOutputStream();
			PipedInputStream pin1 = new PipedInputStream(pout1);

			PipedOutputStream pout2 = new PipedOutputStream();
			PipedInputStream pin2 = new PipedInputStream(pout2);

			/* construct threads */

			Producer prod = new Producer(pout1);
			Filter filt = new Filter(pin1, pout2);
			Consumer cons = new Consumer(pin2);

			/* start threads */

			prod.start();
			filt.start();
			cons.start();

			prod.join();
			filt.join();
			cons.join();
		} catch (IOException e) {
			System.out.println("Error1 : " + e.getMessage());
			e.printStackTrace();
		} catch (InterruptedException e) {
			e.printStackTrace();
		}
		System.out.println("STOP");
	}
}

class Producer extends Thread {

	private DataOutputStream out;

	public Producer(OutputStream os) {
		out = new DataOutputStream(os);
	}

	public void run() {
		try {
			Process p1 = Runtime.getRuntime().exec("find /");
			try {
				InputStreamReader isr = new InputStreamReader(p1
						.getInputStream());
				BufferedReader br = new BufferedReader(isr);
				String line = null;
				while ((line = br.readLine()) != null) {
					out.writeBytes(line + "\n");
					out.flush();
				}
			} catch (IOException ioe) {
				ioe.printStackTrace();
			}
			out.close();
		} catch (Exception e) {
			System.out.println("Error: " + e);
		}
	}

}

class Filter extends Thread {

	private BufferedReader in;
	private DataOutputStream out;

	public Filter(InputStream is, OutputStream os) {
		in = new BufferedReader(new InputStreamReader(is));
		out = new DataOutputStream(os);
	}

	public void run() {
		String s = "";
		while (s != null) {
			try {
				s = in.readLine();
				// TODO apply filters
				out.writeBytes(s + "\n");

			} catch (IOException e) {
				System.out.println("Error: " + e);
			}
		}
		try {
			out.close();
		} catch (IOException e) {
			e.printStackTrace();
		}
	}
}

class Consumer extends Thread {

	private BufferedReader in;

	public Consumer(InputStream is) {
		in = new BufferedReader(new InputStreamReader(is));
	}

	public void run() {
		String s = "";
		while (s != null) {
			try {
				s = in.readLine();
				if (s != null) {
					System.out.println("LINE = " + s);
				}
			} catch (IOException e) {
				System.out.println("Error: " + e);
			}
		}
	}
}