class Consumer extends Thread {

	Buffer buffer;

	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 */
			System.out.println("Consumer terminating");
		}
	}
}