pipedcharacters.java

Java Thread Programming (Source

import java.io.*;

public class PipedCharacters extends Object {
	public static void writeStuff(Writer rawOut) {
		try {
			BufferedWriter out = new BufferedWriter(rawOut);
	
			String[][] line = {
					{ "Java", "has", "nice", "features." },
					{ "Pipes", "are", "interesting." },
					{ "Threads", "are", "fun", "in", "Java." },
					{ "Don't", "you", "think", "so?" }
				};

			for ( int i = 0; i < line.length; i++ ) {
				String[] word = line[i];

				for ( int j = 0; j < word.length; j++ ) {
					if ( j > 0 ) {
						// put a space between words
						out.write(" ");
					} 

					out.write(word[j]);
				}

				// mark the end of a line
				out.newLine();
			}

			out.flush();
			out.close();
		} catch ( IOException x ) {
			x.printStackTrace();
		}
	}

	public static void readStuff(Reader rawIn) {
		try {
			BufferedReader in = new BufferedReader(rawIn);

			String line;
			while ( ( line = in.readLine() ) != null ) {
				System.out.println("read line: " + line);
			}

			System.out.println("Read all data from the pipe");
		} catch ( IOException x ) {
			x.printStackTrace();
		}
	}

	public static void main(String[] args) {
		try {
			final PipedWriter out = new PipedWriter();

			final PipedReader in = new PipedReader(out);

			Runnable runA = new Runnable() {
					public void run() {
						writeStuff(out);
					}
				};

			Thread threadA = new Thread(runA, "threadA");
			threadA.start();
	
			Runnable runB = new Runnable() {
					public void run() {
						readStuff(in);
					}
				};
	
			Thread threadB = new Thread(runB, "threadB");
			threadB.start();
		} catch ( IOException x ) {
			x.printStackTrace();
		}
	}
}