21 |
|
|
22 |
|
public class AbstractQueuedLongSynchronizerTest extends JSR166TestCase { |
23 |
|
public static void main(String[] args) { |
24 |
< |
junit.textui.TestRunner.run(suite()); |
24 |
> |
main(suite(), args); |
25 |
|
} |
26 |
|
public static Test suite() { |
27 |
|
return new TestSuite(AbstractQueuedLongSynchronizerTest.class); |
94 |
|
} |
95 |
|
|
96 |
|
public boolean tryReleaseShared(long ignore) { |
97 |
< |
setState(1 << 62); |
97 |
> |
setState(1L << 62); |
98 |
|
return true; |
99 |
|
} |
100 |
|
} |
246 |
|
long nanosTimeout = MILLISECONDS.toNanos(timeoutMillis); |
247 |
|
long nanosRemaining = c.awaitNanos(nanosTimeout); |
248 |
|
assertTrue(nanosRemaining <= 0); |
249 |
+ |
assertTrue(nanosRemaining > -MILLISECONDS.toNanos(LONG_DELAY_MS)); |
250 |
|
break; |
251 |
|
case awaitUntil: |
252 |
|
assertFalse(c.awaitUntil(delayedDate(timeoutMillis))); |
1198 |
|
public void testTryAcquireSharedNanos_Timeout() { |
1199 |
|
final BooleanLatch l = new BooleanLatch(); |
1200 |
|
final BooleanLatch observedQueued = new BooleanLatch(); |
1200 |
– |
final long timeoutMillis = timeoutMillis(); |
1201 |
|
Thread t = newStartedThread(new CheckedRunnable() { |
1202 |
|
public void realRun() throws InterruptedException { |
1203 |
|
assertFalse(l.isSignalled()); |