如何进行LinkedBlockingQueue的put操作
如何进行LinkedBlockingQueue的put操作
这篇文章将为大家详细讲解有关如何进行LinkedBlockingQueue的put操作，文章内容质量较高，因此小编分享给大家做个参考，希望大家阅读完这篇文章后对相关知识有一定的了解。
JDK提供了7大阻塞队列,常用于实现生产者和消费者,LinkedBlockingQueue是最常用之一.
publicvoidput(Ee)throwsInterruptedException{if(e==null)thrownewNullPointerException();intc=-1;Node<E>node=newNode<E>(e);finalReentrantLockputLock=this.putLock;finalAtomicIntegercount=this.count;//可中断的获取锁操作,即线程由于未获取到锁而处于Blocked状态时,线程可以被中断而不再继续等待.putLock.lockInterruptibly();try{//如果队列中元素数量和队列容量相等,即此时队列已经满了,则当前线程需要等待.//之所以使用while循环,是当线程被唤醒之后,依然需要判断队列是否满.//即只有队列不满的情况下,当前线程才可以添加元素while(count.get()==capacity){notFull.await();}//入队,即添加元素enqueue(node);c=count.getAndIncrement();if(c+1<capacity)//通知其他生产者notFull.signal();}finally{putLock.unlock();}if(c==0)//通知消费者signalNotEmpty();}
总结一下添加操作流程
1.获取putLock锁2.如果队列已满,则等待(notFull.await())3.元素入队4.当前生产者添加元素之后如果队列还没有满,则通知其他生产者添加元素(notFull.signal())5.释放putLock锁6.如果队列中已经有元素,则通知消费者
首先是获取锁,拿到锁之后,如果队列满了则等待,如果队列不满则添加元素,
添加元素之后,如果队列还没有满,则通知其他生产者
添加元素之后,如果队列已经有元素了,则通知消费者
关于如何进行LinkedBlockingQueue的put操作就分享到这里了，希望以上内容可以对大家有一定的帮助，可以学到更多知识。如果觉得文章不错，可以把它分享出去让更多的人看到。
