ArrayBlockingQueue源码分析

末蓝、 2022-12-16 04:00 207阅读 0赞

ArrayBlockingQueue最核心的实现就是一把锁，两个条件。具体看源码如下：

/** Main lock guarding all access */
        final ReentrantLock lock;
    
        /** Condition for waiting takes */
        private final Condition notEmpty;
    
        /** Condition for waiting puts */
        private final Condition notFull;

put和take操作的时候都需要加锁，如果队列满了notFull.wait(),等待消费者消费掉信息后调用notFull.notify()，这样就可以继续put了。如果队列为空的原理也相似。  
下面看下put和take的源码

public void put(E e) throws InterruptedException {
            checkNotNull(e);
            final ReentrantLock lock = this.lock;
            lock.lockInterruptibly();
            try {
                //如果当前数据到达最大值，生产者等待
                while (count == items.length)
                    notFull.await();
                enqueue(e);
            } finally {
                lock.unlock();
            }
        }
        
            public E take() throws InterruptedException {
            final ReentrantLock lock = this.lock;
            lock.lockInterruptibly();
            try {
                //如果当前数据为空，则消费者等待
                while (count == 0)
                    notEmpty.await();
                return dequeue();
            } finally {
                lock.unlock();
            }
        }

发表评论取消回复

表情：

评论列表（有 0 条评论，207人围观）

还没有评论，来说两句吧...

相关阅读

相关【集合】ArrayBlockingQueue 源码分析

前言 Github：[https://github.com/yihonglei/jdk-source-code-reading][https_github.com_yih

Bertha 。/ 2022年12月29日 09:24/ 0 赞/ 145 阅读

相关 ArrayBlockingQueue源码分析

ArrayBlockingQueue最核心的实现就是一把锁，两个条件。具体看源码如下： / Main lock guarding all access /

末蓝、/ 2022年12月16日 04:00/ 0 赞/ 208 阅读

相关阻塞队列ArrayBlockingQueue源码学习

ArrayBlockingQueue总结先直接总结ArrayBlockingQueue相关的特性再根据源码来进行说明，它的主要特性如下： 1. 他是一个由数组实现的

水深无声/ 2022年12月12日 15:18/ 0 赞/ 134 阅读

相关【JUC源码】阻塞队列：ArrayBlockingQueue 源码分析

> 阻塞队列系列： > > [【JUC源码】阻塞队列：继承关系分析][JUC] > [【JUC源码】阻塞队列：ArrayBlockingQueue 源码分析][J

拼搏现实的明天。/ 2022年12月11日 02:26/ 0 赞/ 340 阅读

相关 ArrayBlockingQueue源码详解

阻塞队列插入方法： add(E e) : 添加成功返回true，失败抛IllegalStateException异常 off

墨蓝/ 2022年10月31日 00:58/ 0 赞/ 183 阅读

相关 JDK1.8 ArrayBlockingQueue源码分析

目的：本文通过分析JDK源码来对比ArrayBlockingQueue 和LinkedBlockingQueue，以便日后灵活使用。 1. 在Java的Concurrent包

水深无声/ 2022年07月17日 02:52/ 0 赞/ 238 阅读

相关 Java8 ArrayBlockingQueue 源码阅读

一、什么是 ArrayBlockingQueue `ArrayBlockingQueue` 是 GUC(java.util.concurrent) 包下的一个线程安全的阻

﹏ヽ暗。殇╰゛Y/ 2022年03月25日 15:00/ 0 赞/ 245 阅读

相关死磕 java集合之ArrayBlockingQueue源码分析

问题（1）ArrayBlockingQueue的实现方式？（2）ArrayBlockingQueue是否需要扩容？（3）ArrayBlockingQueue有什

谁践踏了优雅/ 2022年02月16日 07:58/ 0 赞/ 221 阅读

相关 jdk11源码--ArrayBlockingQueue源码分析

> 更多java源码分析请见：jdk11源码分析系列文章专栏：[Java11源码分析][Java11] 文章目录欢迎关注本人公众号概述 Block

逃离我推掉我的手/ 2021年12月18日 19:15/ 0 赞/ 423 阅读

相关 ArrayBlockingQueue源码解读

ArrayBlockingQueue 它是BlockingQueue阻塞队列基于数组的一种实现。阻塞队列：首先它是一个队列queue，同时如果队列为空，从队列取出元

柔情只为你懂/ 2021年09月02日 09:06/ 0 赞/ 465 阅读