910 |
|
Thread t = newStartedThread(new CheckedRunnable() { |
911 |
|
public void realRun() throws InterruptedException { |
912 |
|
threadStarted.countDown(); |
913 |
< |
q.transfer(SIZE); |
913 |
> |
q.transfer(five); |
914 |
|
checkEmpty(q); |
915 |
|
}}); |
916 |
|
|
917 |
|
threadStarted.await(); |
918 |
|
waitForThreadToEnterWaitState(t, SMALL_DELAY_MS); |
919 |
– |
assertTrue(t.isAlive()); |
919 |
|
assertEquals(1, q.size()); |
920 |
< |
assertEquals(SIZE, (int) q.poll()); |
920 |
> |
assertSame(five, q.poll()); |
921 |
|
checkEmpty(q); |
922 |
|
awaitTermination(t, MEDIUM_DELAY_MS); |
923 |
|
} |