Queue.ArrayBlockQueue
Queue.ArrayBlockQueue
脑丨残 发表于7个月前
Queue.ArrayBlockQueue
  • 发表于 7个月前
  • 阅读 6
  • 收藏 0
  • 点赞 0
  • 评论 0

腾讯云 技术升级10大核心产品年终让利>>>   

摘要: 集合

#ArrayBlockQueue

  • 见名知义,数组结构,阻塞队列,线程安全
  • 内部结构
    //存储数组
    final Object[] items;
    //取索引
    int takeIndex;
    //插索引
    int putIndex;
    //元素容量
    int count;
    //同步锁
    final ReentrantLock lock;
    //取阻塞条件
    private final Condition notEmpty;
    //插入阻塞条件
    private final Condition notFull;
  • put 方法,插入,满则等待
//lock 优先考虑获取锁,待获取锁成功后,才响应中断。
//lockInterruptibly 优先考虑响应中断,而不是响应锁的普通获取或重入获取
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();
        }
    }
  • TODO 遍历过程,同步,操作指针
标签: 队列
共有 人打赏支持
粉丝 8
博文 55
码字总数 19033
×
脑丨残
如果觉得我的文章对您有用,请随意打赏。您的支持将鼓励我继续创作!
* 金额(元)
¥1 ¥5 ¥10 ¥20 其他金额
打赏人
留言
* 支付类型
微信扫码支付
打赏金额:
已支付成功
打赏金额: