| 11 |
|
import java.util.concurrent.*; |
| 12 |
|
import java.util.concurrent.atomic.AtomicReference; |
| 13 |
|
import static java.util.concurrent.TimeUnit.MILLISECONDS; |
| 14 |
+ |
import static java.util.concurrent.TimeUnit.NANOSECONDS; |
| 15 |
|
import java.security.CodeSource; |
| 16 |
|
import java.security.Permission; |
| 17 |
|
import java.security.PermissionCollection; |
| 616 |
|
Thread.State s = thread.getState(); |
| 617 |
|
if (s == Thread.State.BLOCKED || |
| 618 |
|
s == Thread.State.WAITING || |
| 619 |
< |
s == Thread.State.TIMED_WAITING || |
| 619 |
< |
System.nanoTime() - t0 > timeoutNanos) |
| 619 |
> |
s == Thread.State.TIMED_WAITING) |
| 620 |
|
return; |
| 621 |
+ |
else if (s == Thread.State.TERMINATED) |
| 622 |
+ |
fail("Unexpected thread termination"); |
| 623 |
+ |
else if (System.nanoTime() - t0 > timeoutNanos) { |
| 624 |
+ |
threadAssertTrue(thread.isAlive()); |
| 625 |
+ |
return; |
| 626 |
+ |
} |
| 627 |
|
Thread.yield(); |
| 628 |
|
} |
| 629 |
|
} |
| 630 |
|
|
| 631 |
|
/** |
| 632 |
+ |
* Returns the number of milliseconds since time given by |
| 633 |
+ |
* startNanoTime, which must have been previously returned from a |
| 634 |
+ |
* call to {@link System.nanoTime()}. |
| 635 |
+ |
*/ |
| 636 |
+ |
long millisElapsedSince(long startNanoTime) { |
| 637 |
+ |
return NANOSECONDS.toMillis(System.nanoTime() - startNanoTime); |
| 638 |
+ |
} |
| 639 |
+ |
|
| 640 |
+ |
/** |
| 641 |
|
* Returns a new started daemon Thread running the given runnable. |
| 642 |
|
*/ |
| 643 |
|
Thread newStartedThread(Runnable runnable) { |
