ブロッキングキューを同期交換する

Question

以下のコードを以下のブロッキングキューに置き換えました。
なぜキューの完全な例外が発生するのですか？それを防ぐことが期待されるブロックキューではありませんか？

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の同等 - wait()とnotify()として

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); 
      } 
     }  
    } 

Answer 1

は操作をブロックしている、あなたはBlockingQueueからブロック操作を使用する必要があります。put()とtake()。そして、一般的な勧告として：は呑み込まないでくださいInterruptedException。 HereはInterruptedExceptionを扱う良い記事です。

だから、​​にごBlockingQueue交換は次のようになります。

BlockingQueue<Integer> b = new ArrayBlockingQueue<Integer>(10); 

class Offer implements Runnable{ 
    Random r=new Random(); 
    public void run(){ 
     while(System.currentTimeMillis() < end){ 
      try { 
       b.put(r.nextInt()); 
      } catch (InterruptedException e) { 
       Thread.currentThread().interrupt(); 
      } 
     } 
    } 
} 

class Take implements Runnable{ 
    public void run(){ 
     while(System.currentTimeMillis() < end){ 
      try { 
       b.take(); 
      } catch (InterruptedException e) { 
       Thread.currentThread().interrupt(); 
      } 
     } 
    } 
}