温馨提示×

温馨提示×

您好,登录后才能下订单哦!

密码登录×
登录注册×
其他方式登录
点击 登录注册 即表示同意《亿速云用户服务条款》

如何进行LinkedBlockingQueue的put操作

发布时间:2021-12-23 17:09:07 来源:亿速云 阅读:94 作者:柒染 栏目:大数据

这篇文章将为大家详细讲解有关如何进行LinkedBlockingQueue的put操作,文章内容质量较高,因此小编分享给大家做个参考,希望大家阅读完这篇文章后对相关知识有一定的了解。

JDK提供了7大阻塞队列,常用于实现生产者和消费者,LinkedBlockingQueue是最常用之一.

public void put(E e) throws InterruptedException {    if (e == null) throw new NullPointerException();    int c = -1;    Node<E> node = new Node<E>(e);    final ReentrantLock putLock = this.putLock;    final AtomicInteger count = this.count;    // 可中断的获取锁操作,即线程由于未获取到锁而处于Blocked状态时,线程可以被中断而不再继续等待.    putLock.lockInterruptibly();    try {        // 如果队列中元素数量和队列容量相等,即此时队列已经满了,则当前线程需要等待.        // 之所以使用while循环,是当线程被唤醒之后,依然需要判断队列是否满.        // 即只有队列不满的情况下,当前线程才可以添加元素                while (count.get() == capacity) {            notFull.await();        }        // 入队,即添加元素        enqueue(node);        c = count.getAndIncrement();        if (c + 1 < capacity)            // 通知其他生产者            notFull.signal();    } finally {        putLock.unlock();    }    if (c == 0)        // 通知消费者        signalNotEmpty();}

总结一下添加操作流程

1.获取putLock锁2.如果队列已满, 则等待(notFull.await())3.元素入队4.当前生产者添加元素之后如果队列还没有满, 则通知其他生产者添加元素(notFull.signal())5.释放putLock锁6.如果队列中已经有元素,则通知消费者

首先是获取锁,拿到锁之后,如果队列满了则等待,如果队列不满则添加元素,

添加元素之后,如果队列还没有满,则通知其他生产者

添加元素之后,如果队列已经有元素了,则通知消费者

关于如何进行LinkedBlockingQueue的put操作就分享到这里了,希望以上内容可以对大家有一定的帮助,可以学到更多知识。如果觉得文章不错,可以把它分享出去让更多的人看到。

向AI问一下细节

免责声明:本站发布的内容(图片、视频和文字)以原创、转载和分享为主,文章观点不代表本网站立场,如果涉及侵权请联系站长邮箱:is@yisu.com进行举报,并提供相关证据,一经查实,将立刻删除涉嫌侵权内容。

AI