Source of SyncBoundedQueue.java


  1: public class SyncBoundedQueue extends BoundedQueue {
  2: 
  3:     public SyncBoundedQueue(int size) {
  4:         super(size);
  5:     }
  6: 
  7:     synchronized public boolean isEmpty() {
  8:         return super.isEmpty();
  9:     }
 10: 
 11:     synchronized public boolean isFull() {
 12:         return  super.isFull();
 13:     }
 14: 
 15:     synchronized public int getCount() {
 16:         return super.getCount();
 17:     }
 18: 
 19:     synchronized public void put(Object e) {
 20:         super.put(e);
 21:     }
 22: 
 23:     synchronized public Object get() {
 24:         return super.get();
 25:     }
 26: 
 27:     public static void main(String args[]) {
 28:         SyncBoundedQueue queue = new SyncBoundedQueue(5);
 29:         new Producer(queue, 45).start();
 30:         new Consumer(queue, 10).start();
 31:     }
 32: }
 33: