-->
  • 39141

    文章

  • 313

    评论

  • 27

    友链

  • 最近新加了换肤功能,大家多来逛逛吧~~~~
  • 喜欢这个网站的朋友可以加一下QQ群,我们一起交流技术。

java生产者消费者专题---谈谈优化(三)

喜欢本站的朋友可以收藏本站,或者加入QQ群:172816590Web网页设计师,我们大家一起来交流技术!

欢迎来到梁钟霖个人博客网站。本个人博客网站提供最新的站长新闻,各种互联网资讯。 还提供个人博客模板,最新最全的java教程,java面试题。在此我将尽我最大所能将此个人博客网站做的最好! 谢谢大家,愿大家一起进步!

java生产者消费者专题---谈谈优化(二)中提到真正需要唤醒的是当队列满的时候唤醒消费者线程,当队列空的时候唤醒生产者线程,但在文章最后指出notifyAll不能换成notify因为还是可能出现死锁,实际上目前并没有真正达到按需唤醒的目的,现使用Condition条件队列进行优化,代码如下:

public class QueueWithCondition<T> extends BlockingQueue<T> {
    private LinkedList<T> queue = new LinkedList<>();
    private Lock lock = new ReentrantLock();
    private Condition full = lock.newCondition();
    private Condition empty = lock.newCondition();
    private final int cacheSize;

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

    public T take() {
        try{
            lock.lock();
            while(true) {
                if(queue.size()>0) {
                    boolean full = queue.size() == cacheSize;
                    T obj = queue.poll();
                    if(full) {
                        this.full.signal();
                    }
                    return obj;
                }else {
                    try {
                        empty.await();
                    } catch (InterruptedException e) {
                    }
                }
            }
        }finally {
            lock.unlock();
        }
    }

    public void put(T obj) {
        try{
            lock.lock();
            while (true) {
                if (queue.size() < cacheSize) {
                    boolean empty=queue.size()==0;
                    queue.offer(obj);
                    if(empty) {
                        this.empty.signal();
                    }
                    break;
                } else {
                    try {
                        full.await();
                    } catch (InterruptedException e) {
                    }
                }

            }
        }finally {
            lock.unlock();
        }

    }

}

改进后平均每秒消费消息72810个比原先每秒消费个数65541要快不少。

使用Condition条件队列可以对不同的等待条件进行分区,这是wait、notify做不到的。


 转载至链接:https://my.oschina.net/u/1268334/blog/3008554。


您觉喜欢本网站,或者觉得本文章对您有帮助,那么可以选择打赏。
打赏多少,您高兴就行,谢谢您对梁钟霖这小子的支持! ~(@^_^@)~

  • 微信扫一扫

    微信打赏
  • 支付宝扫一扫

    支付宝打赏
转载原创文章请注明出处,转载至: 梁钟霖个人博客www.liangzl.com

0条评论

Loading...


发表评论

电子邮件地址不会被公开。 必填项已用*标注

自定义皮肤