不阻塞引起的大祸

在测试服务器上的时候 看到cpu一下到了 200%，然后检查问题，发现是由这样的代码引起的：

private ConcurrentLinkedQueue<PostMassage> postMassages = new ConcurrentLinkedQueue<PostMassage>();
...

public void run() {
      while (true) {
         PostMassage post =postMassages.peek();
         if(post!=null){
            ...
            postMassages.poll();
         }
         ...
      }
   }

从这个代码看，while循环会不断进行，就是在队列为空的情况下也是这样。这个的while操作是很迟cpu的。

解决的办法是采用阻塞的形式，这样：

...
sliceQueue = new LinkedBlockingQueue<byte[]>();
...
public void run() {
while(true) {
try {
data = sliceQueue.take();
                            ...
                     } catch(Exception e) {
                       ...
                     }
             }
      }

这个是阻塞的，而且加入了异常的处理，让这个更健壮。
看看take阻塞的原理，是采用了信号量，这个和wait notify是很类似的

 public E take() throws InterruptedException {
        E x;
        int c = -1;
        final AtomicInteger count = this.count;
        final ReentrantLock takeLock = this.takeLock;
        takeLock.lockInterruptibly();
        try {
                while (count.get() == 0) {
                    notEmpty.await();
                }
            x = dequeue();
            c = count.getAndDecrement();
            if (c > 1)
                notEmpty.signal();
        } finally {
            takeLock.unlock();
        }
        if (c == capacity)
            signalNotFull();
        return x;
    }