BlockingQueue 原理 分析
Posted 超超hd
tags:
篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了BlockingQueue 原理 分析相关的知识,希望对你有一定的参考价值。
ReentrantLock 两个两个比较大的特性。
1.中断
2.定时
3.公平锁。
ReadWriteLock
读读不互斥
读写互斥
写写互斥。
Condition 类似于 Object.wait()和Object.notify()和synchronized配套使用
CountDownLatch lanchi
synchronized
static final CountDownLatch end = new CountDownLatch(10);
end.countDown();
end.await();
CyclicBarrier 循环栅栏 CountDownLatch可以循环使用。
Semaphore
共享锁
运行多个线程同时临界区
ArrayBlockingQueue
ReentrantLock
+两个Condition
/** Main lock guarding all access */
final ReentrantLock lock;
/** Condition for waiting takes */
private final Condition notEmpty;
/** Condition for waiting puts */
private final Condition notFull;
offer
take
当写入时。判断锁unlock 判断条件
是否已经满了,如果慢了 等等 未满Condition的通知条件。
调用insert 插入 然后notEmpty
BlockingQueue
public void put(E e) throws InterruptedException {
checkNotNull(e);
final ReentrantLock lock = this.lock;
lock.lockInterruptibly();
try {
while (count == items.length)
notFull.await();
insert(e);
} finally {
lock.unlock();
}
}
private void insert(E x) {
items[putIndex] = x;
putIndex = inc(putIndex);
++count;
notEmpty.signal();
}
以上是关于BlockingQueue 原理 分析的主要内容,如果未能解决你的问题,请参考以下文章
JUC源码分析-集合篇BlockingQueue 阻塞式队列实现原理
Java多线程:BlockingQueue实现原理(Condition原理)
Java多线程:BlockingQueue实现原理(Condition原理)