producer = p;
final Producer producer = new Producer(); producer.start(); new Consumer( producer ).start(); new Consumer( producer ).start();
try { while ( true ) { String message = producer.getMessage(); System.out.println("Got message: " + message); sleep( 2000 ); } } catch( InterruptedException e ) { }