| # | Line 478 | Line 478 | public class LinkedBlockingQueue<E> exte | |
|---|---|---|
| 478 | final ReentrantLock takeLock = this.takeLock; | |
| 479 | takeLock.lock(); | |
| 480 | try { | |
| 481 | < | Node<E> first = head.next; |
| 482 | < | return (first == null) ? null : first.item; |
| 481 | > | return (count.get() > 0) ? head.next.item : null; |
| 482 | } finally { | |
| 483 | takeLock.unlock(); | |
| 484 | } | |
| – | Removed lines |
| + | Added lines |
| < | Changed lines |
| > | Changed lines |