public class LimitedQueueTest {
    static LimitedQueue queue=new LimitedQueue(5);

    public static void main(String[] args) {
        Runnable adder=new Runnable(){
            public void run(){
                for(int i=0;i<10;i++)
                    LimitedQueueTest.queue.add("Item added by "+
                           Thread.currentThread());
            }
        };        

   Runnable taker=new Runnable(){
            public void run(){
                Object o;
                try {
                    for(int i=0;i<30;i++){
                        o = LimitedQueueTest.queue.take();
                        System.out.println(o);
                     }
                } catch (InterruptedException e) { e.printStackTrace(); }
            }
        };
       Thread adderThA=new Thread(adder);
       adderThA.start();
       Thread adderThB=new Thread(adder);
       adderThB.start();


Thread takerTh=new Thread(taker);
        takerTh.start();
        try {
            System.out.println(“主線睡眠5秒，takerTh線程等待…);
            Thread.sleep(5000);
            System.out.println(“主線恢復，啟動adderThC線程”);
         } catch (InterruptedException e) {
             e.printStackTrace();
         }
        Thread adderThC=new Thread(adder);
         adderThC.start();
    }
}