/libcore/jsr166-tests/src/test/java/jsr166/ |
D | CyclicBarrierTest.java | 126 Thread t2 = new ThreadShouldThrow(BrokenBarrierException.class) { in testAwait1_Interrupted_BrokenBarrier() local 133 t2.start(); in testAwait1_Interrupted_BrokenBarrier() 137 awaitTermination(t2); in testAwait1_Interrupted_BrokenBarrier() 152 Thread t2 = new ThreadShouldThrow(BrokenBarrierException.class) { in testAwait2_Interrupted_BrokenBarrier() local 159 t2.start(); in testAwait2_Interrupted_BrokenBarrier() 163 awaitTermination(t2); in testAwait2_Interrupted_BrokenBarrier() 197 Thread t2 = newStartedThread(new CheckedRunnable() { in testAwait4_Timeout_BrokenBarrier() local 209 awaitTermination(t2); in testAwait4_Timeout_BrokenBarrier() 225 Thread t2 = newStartedThread(new CheckedRunnable() { in testAwait5_Timeout_BrokenBarrier() local 237 awaitTermination(t2); in testAwait5_Timeout_BrokenBarrier() [all …]
|
D | AbstractQueuedLongSynchronizerTest.java | 287 Thread t2 = newStartedThread(new InterruptibleSyncRunnable(sync)); in testHasQueuedThreads() local 288 waitForQueuedThread(sync, t2); in testHasQueuedThreads() 294 awaitTermination(t2); in testHasQueuedThreads() 315 Thread t2 = new Thread(new InterruptibleSyncRunnable(sync)); in testIsQueued() local 317 assertFalse(sync.isQueued(t2)); in testIsQueued() 322 assertFalse(sync.isQueued(t2)); in testIsQueued() 323 t2.start(); in testIsQueued() 324 waitForQueuedThread(sync, t2); in testIsQueued() 326 assertTrue(sync.isQueued(t2)); in testIsQueued() 330 assertTrue(sync.isQueued(t2)); in testIsQueued() [all …]
|
D | AbstractQueuedSynchronizerTest.java | 290 Thread t2 = newStartedThread(new InterruptibleSyncRunnable(sync)); in testHasQueuedThreads() local 291 waitForQueuedThread(sync, t2); in testHasQueuedThreads() 297 awaitTermination(t2); in testHasQueuedThreads() 318 Thread t2 = new Thread(new InterruptibleSyncRunnable(sync)); in testIsQueued() local 320 assertFalse(sync.isQueued(t2)); in testIsQueued() 325 assertFalse(sync.isQueued(t2)); in testIsQueued() 326 t2.start(); in testIsQueued() 327 waitForQueuedThread(sync, t2); in testIsQueued() 329 assertTrue(sync.isQueued(t2)); in testIsQueued() 333 assertTrue(sync.isQueued(t2)); in testIsQueued() [all …]
|
D | ReentrantLockTest.java | 229 Thread t2 = new Thread(new InterruptibleLockRunnable(lock)); in testHasQueuedThreads() local 236 t2.start(); in testHasQueuedThreads() 237 waitForQueuedThread(lock, t2); in testHasQueuedThreads() 243 awaitTermination(t2); in testHasQueuedThreads() 255 Thread t2 = new Thread(new InterruptibleLockRunnable(lock)); in testGetQueueLength() local 261 t2.start(); in testGetQueueLength() 262 waitForQueuedThread(lock, t2); in testGetQueueLength() 268 awaitTermination(t2); in testGetQueueLength() 293 Thread t2 = new Thread(new InterruptibleLockRunnable(lock)); in testHasQueuedThread() local 295 assertFalse(lock.hasQueuedThread(t2)); in testHasQueuedThread() [all …]
|
D | ReentrantReadWriteLockTest.java | 488 Thread t2 = newStartedThread(new CheckedRunnable() { in testWriteAfterMultipleReadLocks() local 495 waitForQueuedThread(lock, t2); in testWriteAfterMultipleReadLocks() 501 awaitTermination(t2); in testWriteAfterMultipleReadLocks() 525 Thread t2 = newStartedThread(new CheckedRunnable() { in testReaderWriterReaderFairFifo() local 533 waitForQueuedThread(lock, t2); in testReaderWriterReaderFairFifo() 539 awaitTermination(t2); in testReaderWriterReaderFairFifo() 557 Thread t2 = newStartedThread(new CheckedRunnable() { in testReadAfterWriteLock() local 564 waitForQueuedThread(lock, t2); in testReadAfterWriteLock() 567 awaitTermination(t2); in testReadAfterWriteLock() 602 Thread t2 = newStartedThread(new CheckedRunnable() { in testReadTryLockBarging() local [all …]
|
D | ExchangerTest.java | 30 Thread t2 = newStartedThread(new CheckedRunnable() { in testExchange() local 37 awaitTermination(t2); in testExchange() 50 Thread t2 = newStartedThread(new CheckedRunnable() { in testTimedExchange() local 57 awaitTermination(t2); in testTimedExchange() 125 Thread t2 = newStartedThread(new CheckedRunnable() { in testReplacementAfterExchange() local 142 awaitTermination(t2); in testReplacementAfterExchange()
|
D | SemaphoreTest.java | 283 Thread t2 = newStartedThread(new CheckedRunnable() { in testUninterruptible() local 293 waitForQueuedThread(s, t2); in testUninterruptible() 294 t2.interrupt(); in testUninterruptible() 297 assertTrue(t2.isAlive()); in testUninterruptible() 302 awaitTermination(t2); in testUninterruptible() 317 Thread t2 = newStartedThread(new InterruptibleLockRunnable(lock)); in testHasQueuedThreads() local 318 waitForQueuedThread(lock, t2); in testHasQueuedThreads() 324 awaitTermination(t2); in testHasQueuedThreads() 340 Thread t2 = newStartedThread(new InterruptibleLockRunnable(lock)); in testGetQueueLength() local 341 waitForQueuedThread(lock, t2); in testGetQueueLength() [all …]
|
D | FutureTaskTest.java | 543 Thread t2 = newStartedThread(new CheckedRunnable() { in testGetRun() local 552 assertTrue(t2.isAlive()); in testGetRun() 559 awaitTermination(t2); in testGetRun() 582 Thread t2 = newStartedThread(new CheckedRunnable() { in testGetSet() local 591 assertTrue(t2.isAlive()); in testGetSet() 599 awaitTermination(t2); in testGetSet() 635 Thread t2 = new ThreadShouldThrow(CancellationException.class) { in testTimedGet_Cancellation() local 641 t2.start(); in testTimedGet_Cancellation() 648 awaitTermination(t2); in testTimedGet_Cancellation()
|
D | AtomicLongArrayTest.java | 305 Thread t2 = new Thread(c2); in testCountingInMultipleThreads() local 307 t2.start(); in testCountingInMultipleThreads() 309 t2.join(); in testCountingInMultipleThreads()
|
D | AtomicIntegerArrayTest.java | 305 Thread t2 = new Thread(c2); in testCountingInMultipleThreads() local 307 t2.start(); in testCountingInMultipleThreads() 309 t2.join(); in testCountingInMultipleThreads()
|
D | PhaserTest.java | 470 Thread t2 = newStartedThread(new CheckedRunnable() { 489 assertThreadsStayAlive(t1, t2); 491 t2.interrupt(); 493 awaitTermination(t2);
|
D | SynchronousQueueTest.java | 572 Thread t2 = newStartedThread(new CheckedRunnable() { 586 awaitTermination(t2);
|
/libcore/luni/src/test/java/libcore/java/lang/ |
D | ThreadTest.java | 106 WakeupTestThread t2 = new WakeupTestThread(); in testThreadWakeup() local 109 t2.start(); in testThreadWakeup() 110 assertTrue("Threads already finished", !t1.done && !t2.done); in testThreadWakeup() 113 t2.interrupt(); in testThreadWakeup() 116 assertTrue("Threads did not finish", t1.done && t2.done); in testThreadWakeup() 158 Thread t2 = new Thread(group, "t2") { in testGetAllStackTracesIncludesAllGroups() local 163 t2.start(); in testGetAllStackTracesIncludesAllGroups() 164 t2.join(); in testGetAllStackTracesIncludesAllGroups()
|
/libcore/luni/src/test/java/libcore/java/sql/ |
D | TimestampTest.java | 35 Timestamp t2 = new Timestamp(Long.MIN_VALUE + 1); in testToString() local 36 assertEquals("292278994-08-17 07:12:55.193", t2.toString()); in testToString() 58 Timestamp t2 = Timestamp.valueOf("2001-01-02 01:05:07.123"); in testValueOf() local 59 assertEquals(978397507000L + 123000000 / 1000000, t2.getTime()); in testValueOf() 60 assertEquals(123000000, t2.getNanos()); in testValueOf()
|
D | OldResultSetGetterTests.java | 948 Time t2 = new java.sql.Time(millis2); in testGetTimeInt() local 962 assertEquals(t2.toString(), resTime.toString()); in testGetTimeInt() 963 assertEquals(t2.getTime(), resTime.getTime()); in testGetTimeInt() 964 assertEquals(t2, resTime); in testGetTimeInt() 1005 Time t2 = new java.sql.Time(millis2); in testGetTimeIntCalendar() local 1022 assertEquals(t2.toString(), timeRes.toString()); in testGetTimeIntCalendar() 1023 assertEquals(t2.getTime(), timeRes.getTime()); in testGetTimeIntCalendar() 1024 assertEquals(t2, timeRes); in testGetTimeIntCalendar() 1078 Time t2 = new java.sql.Time(millis2); in testGetTimeString() local 1084 assertEquals(t2.toString(), timeRes.toString()); in testGetTimeString() [all …]
|
/libcore/luni/src/test/java/com/android/org/bouncycastle/crypto/digests/ |
D | DigestTest.java | 70 long t2 = System.currentTimeMillis(); in doTestMessageDigest() local 77 newTime = newTime + (t3 - t2); in doTestMessageDigest()
|
/libcore/luni/src/main/java/java/util/concurrent/ |
D | ForkJoinTask.java | 716 public static void invokeAll(ForkJoinTask<?> t1, ForkJoinTask<?> t2) { in invokeAll() argument 718 t2.fork(); in invokeAll() 721 if ((s2 = t2.doJoin() & DONE_MASK) != NORMAL) in invokeAll() 722 t2.reportException(s2); in invokeAll()
|
/libcore/harmony-tests/src/test/java/org/apache/harmony/tests/java/io/ |
D | ObjectOutputStreamTest.java | 708 ExternalTest t2 = (ExternalTest) ois.readObject(); in test_useProtocolVersionI() local 712 + t2.getValue(), t1.getValue().equals(t2.getValue())); in test_useProtocolVersionI()
|