java生产者消费者专题---谈谈优化（二）

在java生产者消费者专题---谈谈优化（一）中说明了当知足唤醒条件时须要使用notifyAll而不是notify，可是notifyAll依然存在效率上的问题，由于notifyAll唤醒的是全部线程，因为生产者线程会在队列满的时候进入等待、消费者线程会在队列为空的时候进入等待，所以生产者须要唤醒的条件就是队列满了、消费者须要唤醒的条件就是队列空了，不能像原来同样不加检测条件直接唤醒，因而程序优化以下：

package pro_con;

import java.util.LinkedList;

public class QueueWithWait2<T> extends BlockingQueue<T> {
    private LinkedList<T> queue = new LinkedList<>();
    private final int cacheSize;

    public QueueWithWait2(int cacheSize) {
        super();
        this.cacheSize = cacheSize;
    }

    public T take() {
        synchronized (queue) {
            while(true) {
                if(queue.size()>0) {
                    boolean full = queue.size() == cacheSize;
                    T obj = queue.poll();
                    if(full) {
                        queue.notifyAll();
                    }
                    return obj;
                }else {
                    try {
                        queue.wait();
                    } catch (InterruptedException e) {
                    }
                }
            }
        }
    }

    public void put(T obj) {

        synchronized (queue) {
            while (true) {
                if (queue.size() < cacheSize) {
                    boolean empty=queue.size()==0;
                    queue.offer(obj);
                    if(empty) {
                        queue.notifyAll();
                    }
                    break;
                } else {
                    try {
                        queue.wait();
                    } catch (InterruptedException e) {
                    }
                }

            }
        }

    }

}

改进后平均每秒消费消息65541个比原先每秒消费个数63523稍微快点。

注意这里的notifyAll还不能换成notify由于还会发生相似 java生产者消费者专题---谈谈优化（一）中的死锁状况，其实这里也并无真正达到按需唤醒的目标，会在下一篇进行分析。