# | Line 590 | Line 590 | public class SynchronousQueueTest extend | |
---|---|---|
590 | }}); | |
591 | ||
592 | ArrayList l = new ArrayList(); | |
593 | < | delay(SHORT_DELAY_MS); |
594 | < | q.drainTo(l, 1); |
593 | > | int drained; |
594 | > | while ((drained = q.drainTo(l, 1)) == 0) Thread.yield(); |
595 | > | assertEquals(1, drained); |
596 | assertEquals(1, l.size()); | |
597 | < | q.drainTo(l, 1); |
597 | > | while ((drained = q.drainTo(l, 1)) == 0) Thread.yield(); |
598 | > | assertEquals(1, drained); |
599 | assertEquals(2, l.size()); | |
600 | assertTrue(l.contains(one)); | |
601 | assertTrue(l.contains(two)); |
– | Removed lines |
+ | Added lines |
< | Changed lines |
> | Changed lines |