import java.util.Random; public class Consumer extends Thread{ public Consumer(BoundedBuffer buffer, int num, String name, int speed){ _buffer = buffer; _n = num; _name = name; _speed = speed; } public void run(){ for (int i = 0; i < _n; ++i){ BBItem itm =_buffer.get(); System.out.println("Consumer: " + _name + " consuming: " + itm); // producing item - random time Random rg = new Random(System.currentTimeMillis()); int time = rg.nextInt(_speed); try { sleep(time); } catch(Exception e){ System.out.println(e); } } } protected BoundedBuffer _buffer; protected int _n, _speed; protected String _name; }