353 |
|
}}); |
354 |
|
|
355 |
|
t.start(); |
356 |
< |
Thread.sleep(SHORT_DELAY_MS); |
356 |
> |
delay(SHORT_DELAY_MS); |
357 |
|
q.take(); |
358 |
|
t.interrupt(); |
359 |
|
t.join(); |
373 |
|
}}); |
374 |
|
|
375 |
|
t.start(); |
376 |
< |
Thread.sleep(SMALL_DELAY_MS); |
376 |
> |
delay(SMALL_DELAY_MS); |
377 |
|
t.interrupt(); |
378 |
|
t.join(); |
379 |
|
} |
406 |
|
assertTrue(millisElapsedSince(t0) >= SHORT_DELAY_MS); |
407 |
|
}}); |
408 |
|
threadStarted.await(); |
409 |
< |
Thread.sleep(SHORT_DELAY_MS); |
409 |
> |
delay(SHORT_DELAY_MS); |
410 |
|
assertTrue(t.isAlive()); |
411 |
|
t.interrupt(); |
412 |
|
awaitTermination(t, MEDIUM_DELAY_MS); |
430 |
|
}}); |
431 |
|
|
432 |
|
t.start(); |
433 |
< |
Thread.sleep(SHORT_DELAY_MS); |
433 |
> |
delay(SHORT_DELAY_MS); |
434 |
|
t.interrupt(); |
435 |
|
t.join(); |
436 |
|
} |
487 |
|
}}); |
488 |
|
|
489 |
|
t.start(); |
490 |
< |
Thread.sleep(SHORT_DELAY_MS); |
490 |
> |
delay(SHORT_DELAY_MS); |
491 |
|
t.interrupt(); |
492 |
|
t.join(); |
493 |
|
} |
773 |
|
|
774 |
|
executor.execute(new CheckedRunnable() { |
775 |
|
public void realRun() throws InterruptedException { |
776 |
< |
Thread.sleep(SHORT_DELAY_MS); |
776 |
> |
delay(SHORT_DELAY_MS); |
777 |
|
q.put(new PDelay(1)); |
778 |
|
}}); |
779 |
|
|