import java.util.Vector;

class Consumer extends Thread {
    Producer producer;
	
    Consumer(Producer p) {
		producer = p;
    }
 
    public void run() {
		try {
			while ( true ) {
				String message = producer.getMessage();
				System.out.println("Got message: " + message);
				sleep( 2000 );
			}
		} catch( InterruptedException e ) { }
    }
 
    public static void main(String args[]) {
        final Producer producer = new Producer();
		producer.start();
        new Consumer( producer ).start();
        new Consumer( producer ).start();
    }
}