阻塞队列取代同步(Blocking queue to replace synchronized)

 我用下面的阻塞队列替换了下面的代码。 
 为什么我会得到一个队列完整的异常 - 是不是阻塞队列可以预防这种情况？ 
 
    class Offer implements Runnable{
        Random r=new Random();
        public void run(){
            while(System.currentTimeMillis() < end){
                synchronized(b){
                    try{
                        while(b.size()>10){
                            b.wait();
                        }
                        b.add(r.nextInt());
                        b.notify();

                    }catch(InterruptedException x){}
                }
            }
        }       
    }

    class Take implements Runnable{
        public void run(){
            while(System.currentTimeMillis() < end){
                synchronized(b){
                    try{
                        while(b.size()<1){
                            b.wait();
                        }   
                        b.remove(0);
                        b.notify();


                    }catch(InterruptedException x){}
                }
            }
        }       
    }
 
 阻塞队列相当于 - 
 
BlockingQueue<Integer> b = new ArrayBlockingQueue<Integer>(10);
    class Offer implements Runnable{
        Random r=new Random();
        public void run(){
            while(System.currentTimeMillis() < end){
                b.add(r.nextInt());
            }
        }       
    }

    class Take implements Runnable{
        public void run(){
            while(System.currentTimeMillis() < end){
                b.remove(0);
            }
        }       
    }

I replaced the following code with the blocking Queue below.
 Why do I get a queue full exception - isn't the blocking queue expected to prevent just that? 
 
    class Offer implements Runnable{
        Random r=new Random();
        public void run(){
            while(System.currentTimeMillis() < end){
                synchronized(b){
                    try{
                        while(b.size()>10){
                            b.wait();
                        }
                        b.add(r.nextInt());
                        b.notify();

                    }catch(InterruptedException x){}
                }
            }
        }       
    }

    class Take implements Runnable{
        public void run(){
            while(System.currentTimeMillis() < end){
                synchronized(b){
                    try{
                        while(b.size()<1){
                            b.wait();
                        }   
                        b.remove(0);
                        b.notify();


                    }catch(InterruptedException x){}
                }
            }
        }       
    }
 
THe blockingqueue equivalent - 
 
BlockingQueue<Integer> b = new ArrayBlockingQueue<Integer>(10);
    class Offer implements Runnable{
        Random r=new Random();
        public void run(){
            while(System.currentTimeMillis() < end){
                b.add(r.nextInt());
            }
        }       
    }

    class Take implements Runnable{
        public void run(){
            while(System.currentTimeMillis() < end){
                b.remove(0);
            }
        }       
    }

原文：https://stackoverflow.com/questions/43956250