138 |
|
}}); |
139 |
|
|
140 |
|
await(pleaseInterrupt); |
141 |
< |
assertThreadStaysAlive(t); |
141 |
> |
assertThreadBlocks(t, Thread.State.WAITING); |
142 |
|
t.interrupt(); |
143 |
|
awaitTermination(t); |
144 |
|
assertEquals(0, q.remainingCapacity()); |
172 |
|
catch (InterruptedException e) { threadUnexpectedException(e); } |
173 |
|
|
174 |
|
await(pleaseInterrupt); |
175 |
< |
assertThreadStaysAlive(t); |
175 |
> |
assertThreadBlocks(t, Thread.State.WAITING); |
176 |
|
t.interrupt(); |
177 |
|
awaitTermination(t); |
178 |
|
assertEquals(0, q.remainingCapacity()); |
199 |
|
}}); |
200 |
|
|
201 |
|
await(pleaseInterrupt); |
202 |
< |
assertThreadStaysAlive(t); |
202 |
> |
assertThreadBlocks(t, Thread.State.TIMED_WAITING); |
203 |
|
t.interrupt(); |
204 |
|
awaitTermination(t); |
205 |
|
} |
282 |
|
assertTrue(millisElapsedSince(startTime) < LONG_DELAY_MS); |
283 |
|
|
284 |
|
await(pleaseInterrupt); |
285 |
< |
assertThreadStaysAlive(t); |
285 |
> |
assertThreadBlocks(t, Thread.State.TIMED_WAITING); |
286 |
|
t.interrupt(); |
287 |
|
awaitTermination(t); |
288 |
|
} |
401 |
|
public void testToArray2() { testToArray2(false); } |
402 |
|
public void testToArray2_fair() { testToArray2(true); } |
403 |
|
public void testToArray2(boolean fair) { |
404 |
< |
final SynchronousQueue<Integer> q |
405 |
< |
= new SynchronousQueue<Integer>(fair); |
404 |
> |
final SynchronousQueue<Integer> q = new SynchronousQueue<>(fair); |
405 |
|
Integer[] a; |
406 |
|
|
407 |
|
a = new Integer[0]; |
569 |
|
fail("timed out"); |
570 |
|
Thread.yield(); |
571 |
|
} |
572 |
< |
assertTrue(l.size() == 1); |
572 |
> |
assertEquals(1, l.size()); |
573 |
|
assertSame(one, l.get(0)); |
574 |
|
awaitTermination(t); |
575 |
|
} |