492 |
|
}}); |
493 |
|
|
494 |
|
await(aboutToLock); |
495 |
< |
waitForThreadToEnterWaitState(t); |
495 |
> |
assertThreadBlocks(t, Thread.State.WAITING); |
496 |
|
assertFalse(lock.isWriteLocked()); |
497 |
|
assertTrue(lock.isReadLocked()); |
498 |
|
lock.unlockRead(rs); |
546 |
|
Thread t2 = newStartedThread(acquireReleaseReadLock); |
547 |
|
|
548 |
|
await(threadsStarted); |
549 |
< |
waitForThreadToEnterWaitState(t1); |
550 |
< |
waitForThreadToEnterWaitState(t2); |
549 |
> |
assertThreadBlocks(t1, Thread.State.WAITING); |
550 |
> |
assertThreadBlocks(t2, Thread.State.WAITING); |
551 |
|
assertTrue(lock.isWriteLocked()); |
552 |
|
assertFalse(lock.isReadLocked()); |
553 |
|
releaseWriteLock(lock, s); |
753 |
|
await(locked); |
754 |
|
assertFalse(lock.validate(p)); |
755 |
|
assertEquals(0L, lock.tryOptimisticRead()); |
756 |
< |
waitForThreadToEnterWaitState(t); |
756 |
> |
assertThreadBlocks(t, Thread.State.WAITING); |
757 |
|
t.interrupt(); |
758 |
|
awaitTermination(t); |
759 |
|
assertTrue(lock.isWriteLocked()); |