PriorityBlockingQueue是线程安全的，之前我们看过priorityqueue的实现原理，https://www.jianshu.com/p/b0a2615f1bba?v=1672747035605
今天我们看一下PriorityBlockingQueue怎么实现线程安全的
有个类的全局变量retrantlock。是在PriorityBlockingQueue的构造方法里面新建的。
offer方法里面使用了retrantlock锁处理保证线程安全
在offer元素过程中可能需要扩容
扩容代码实现
private void tryGrow(Object[] array, int oldCap) {
lock.unlock(); // must release and then re-acquire main lock。//注释一 释放全局锁
Object[] newArray =null;
if (allocationSpinLock ==0 &&UNSAFE.compareAndSwapInt(this, allocationSpinLockOffset, 0, 1)) {//注释二
try {
int newCap = oldCap + ((oldCap <64) ?
(oldCap +2) :// grow faster if small
(oldCap >>1));
if (newCap -MAX_ARRAY_SIZE >0) {// possible overflow
int minCap = oldCap +1;
if (minCap <0 || minCap >MAX_ARRAY_SIZE)
throw new OutOfMemoryError();
newCap =MAX_ARRAY_SIZE;
}
if (newCap > oldCap &&queue == array)
newArray =new Object[newCap];
}finally {
allocationSpinLock =0;
}
}if (newArray ==null)// back off if another thread is allocating
Thread.yield();
lock.lock(); //注释三
if (newArray !=null &&queue == array) {
queue = newArray;
System.arraycopy(array, 0, newArray, 0, oldCap);
}}
入队时如何保证线程安全和效率
1.offer方法里面获取了自旋锁，保证了只有一个线程进行添加操作。
2.扩容方法（注释一 ）会释放锁。这样保证offer方法可以进行入队操作
3.注释二 cas操作保证只有一个线程进行扩容
4.然后获取锁进行数据拷贝到扩容后的数组，因为这个操作会随着数据的增长耗费些时间。
所以采用了加锁操作。其他线程会进行yield然后进行自旋。
出队时用的就是加锁来实现的
