import java.util.*; class Consumer extends Thread { public Consumer(BoundedBuffer b, String name) { super(name); buffer = b; } public void run() { String message; while (true) { BoundedBuffer.napping(3); // consume an item from the buffer message = (String)buffer.remove(); } } private BoundedBuffer buffer; }