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();
}