322 |
|
}}); |
323 |
|
|
324 |
|
await(pleaseTake); |
325 |
< |
assertEquals(q.remainingCapacity(), 0); |
325 |
> |
assertEquals(0, q.remainingCapacity()); |
326 |
|
assertEquals(0, q.take()); |
327 |
|
|
328 |
|
await(pleaseInterrupt); |
329 |
|
assertThreadStaysAlive(t); |
330 |
|
t.interrupt(); |
331 |
|
awaitTermination(t); |
332 |
< |
assertEquals(q.remainingCapacity(), 0); |
332 |
> |
assertEquals(0, q.remainingCapacity()); |
333 |
|
} |
334 |
|
|
335 |
|
/** |
774 |
|
ArrayBlockingQueue q = populatedQueue(SIZE); |
775 |
|
ArrayList l = new ArrayList(); |
776 |
|
q.drainTo(l); |
777 |
< |
assertEquals(q.size(), 0); |
778 |
< |
assertEquals(l.size(), SIZE); |
777 |
> |
assertEquals(0, q.size()); |
778 |
> |
assertEquals(SIZE, l.size()); |
779 |
|
for (int i = 0; i < SIZE; ++i) |
780 |
|
assertEquals(l.get(i), new Integer(i)); |
781 |
|
q.add(zero); |
785 |
|
assertTrue(q.contains(one)); |
786 |
|
l.clear(); |
787 |
|
q.drainTo(l); |
788 |
< |
assertEquals(q.size(), 0); |
789 |
< |
assertEquals(l.size(), 2); |
788 |
> |
assertEquals(0, q.size()); |
789 |
> |
assertEquals(2, l.size()); |
790 |
|
for (int i = 0; i < 2; ++i) |
791 |
|
assertEquals(l.get(i), new Integer(i)); |
792 |
|
} |