阻塞原理：比如，一个队列中有8个格子，代表可放入8条数据，当一条信息到来就放入一个格子中，然后就进行处理。但是这个时候一次性来了8条数据，格子满了，数据还没有处理完，就来个一条数据。这个时候就把这条数据进行阻塞。

示例：假定有一个绑定的缓冲区，它支持 put 和take 方法。如果试图在空的缓冲区上执行 take 操作，则在某一个项变得可用之前，线程将一直阻塞；如果试图在满的缓冲区上执行put 操作，则在有空间变得可用之前，线程将一直阻塞。我们喜欢在单独的等待 set 中保存 put 线程和 take 线程，这样就可以在缓冲区中的项或空间变得可用时利用最佳规划，一次只通知一个线程。可以使用两个Condition实例来做到这一点。

BoundedBuffer源码

 class BoundedBuffer {
   final Lock lock = new ReentrantLock();
   final Condition notFull  = lock.newCondition(); 
   final Condition notEmpty = lock.newCondition(); 

   final Object[] items = new Object[100];  //最多<span style="font-family:SimSun;">100个格子</span>
   int putptr, takeptr, count;
   <span style="font-family:SimSun;">   /**放数据*/</span>
   public void put(Object x) throws InterruptedException {
     lock.lock();
     try {
       while (count == items.length) //如果<span style="font-family:SimSun;">等于100放满了，</span>就阻塞<span style="font-family:SimSun;">队列</span>
         notFull.await();  //睡眠
       items[putptr] = x; 
       if (++putptr == items.length) putptr = 0;  <span style="font-family:SimSun;">//从0开始，放到99就又从新开始放。</span>
       ++count;  //<span style="font-family:SimSun;">放</span>一条数据，就<span style="font-family:SimSun;">加</span>1
       notEmpty.signal();  //唤醒
     } finally {
       lock.unlock();
     }
   }
   <pre name="code" class="java"><span style="font-family:SimSun;">   /**取数据*/</span>
   public Object take() throws InterruptedException {
     lock.lock();
     try {
       while (count == 0) <span style="font-family:SimSun;"> </span>//如果<span style="font-family:SimSun;">等于0没有数据，</span>就阻塞<span style="font-family:SimSun;">队列</span>
         notEmpty.await();  //睡眠
       Object x = items[takeptr]; 
       if (++takeptr == items.length) takeptr = 0;<span style="font-family:SimSun;"> //从0开始，取到99就又从新开始取。</span>
       --count;  //取一条就减去1
       notFull.signal();//唤醒
       return x;
     } finally {
       lock.unlock();
     }
   } 
 }

    在唤醒的时候，会把放数据和取数据的线程都会唤醒。使用两个Condition便于区分，取和放。

    在放完数据时候，就唤醒取的线程。

    在取完的时候，就唤醒放的线程。

可阻塞队列-原理及源码解析