# | Line 585 | Line 585 | public class LinkedTransferQueue<E> exte | |
---|---|---|
585 | } | |
586 | } | |
587 | ||
588 | + | public boolean isEmpty() { |
589 | + | for (;;) { |
590 | + | QNode h = traversalHead(); |
591 | + | QNode p = h.next; |
592 | + | if (p == null) |
593 | + | return true; |
594 | + | Object x = p.get(); |
595 | + | if (p != x) { |
596 | + | if (!p.isData) |
597 | + | return true; |
598 | + | if (x != null) |
599 | + | return false; |
600 | + | } |
601 | + | } |
602 | + | } |
603 | + | |
604 | public boolean hasWaitingConsumer() { | |
605 | for (;;) { | |
606 | QNode h = traversalHead(); |
– | Removed lines |
+ | Added lines |
< | Changed lines |
> | Changed lines |