643 |
|
LinkedTransferQueue q = populatedQueue(SIZE); |
644 |
|
ArrayList l = new ArrayList(); |
645 |
|
q.drainTo(l); |
646 |
< |
assertEquals(q.size(), 0); |
647 |
< |
assertEquals(l.size(), SIZE); |
646 |
> |
assertEquals(0, q.size()); |
647 |
> |
assertEquals(SIZE, l.size()); |
648 |
|
for (int i = 0; i < SIZE; ++i) { |
649 |
|
assertEquals(l.get(i), i); |
650 |
|
} |
655 |
|
assertTrue(q.contains(one)); |
656 |
|
l.clear(); |
657 |
|
q.drainTo(l); |
658 |
< |
assertEquals(q.size(), 0); |
659 |
< |
assertEquals(l.size(), 2); |
658 |
> |
assertEquals(0, q.size()); |
659 |
> |
assertEquals(2, l.size()); |
660 |
|
for (int i = 0; i < 2; ++i) { |
661 |
|
assertEquals(l.get(i), i); |
662 |
|
} |
709 |
|
*/ |
710 |
|
public void testWaitingConsumer() throws InterruptedException { |
711 |
|
final LinkedTransferQueue q = new LinkedTransferQueue(); |
712 |
< |
assertEquals(q.getWaitingConsumerCount(), 0); |
712 |
> |
assertEquals(0, q.getWaitingConsumerCount()); |
713 |
|
assertFalse(q.hasWaitingConsumer()); |
714 |
|
final CountDownLatch threadStarted = new CountDownLatch(1); |
715 |
|
|
717 |
|
public void realRun() throws InterruptedException { |
718 |
|
threadStarted.countDown(); |
719 |
|
assertSame(one, q.poll(LONG_DELAY_MS, MILLISECONDS)); |
720 |
< |
assertEquals(q.getWaitingConsumerCount(), 0); |
720 |
> |
assertEquals(0, q.getWaitingConsumerCount()); |
721 |
|
assertFalse(q.hasWaitingConsumer()); |
722 |
|
}}); |
723 |
|
|
724 |
|
threadStarted.await(); |
725 |
|
waitForThreadToEnterWaitState(t, SMALL_DELAY_MS); |
726 |
< |
assertEquals(q.getWaitingConsumerCount(), 1); |
726 |
> |
assertEquals(1, q.getWaitingConsumerCount()); |
727 |
|
assertTrue(q.hasWaitingConsumer()); |
728 |
|
|
729 |
|
assertTrue(q.offer(one)); |
730 |
< |
assertEquals(q.getWaitingConsumerCount(), 0); |
730 |
> |
assertEquals(0, q.getWaitingConsumerCount()); |
731 |
|
assertFalse(q.hasWaitingConsumer()); |
732 |
|
|
733 |
|
awaitTermination(t, MEDIUM_DELAY_MS); |