public class Consumer extends Thread {

	Buffer buffer;

	public Consumer(Buffer b) {
		buffer = b;
	}

	public void run() {
		try {
			while (true) {
				System.out.println("Found " + buffer.get());
			}
		} catch (InterruptedException e) {
			/* Consumer will be interrupted when it should finish */
		}
	}
}