/libcore/luni/src/test/java/libcore/java/nio/channels/ |
D | FutureLikeCompletionHandler.java | 24 boolean done; field in FutureLikeCompletionHandler 30 if (done) { in completed() 34 this.done = true; in completed() 42 if (done) { in failed() 46 this.done = true; in failed() 54 while (!done) { in get()
|
/libcore/jsr166-tests/src/test/java/jsr166/ |
D | ThreadPoolExecutorTest.java | 96 final CountDownLatch done = new CountDownLatch(1); in testExecute() local 98 public void realRun() { done.countDown(); }}; in testExecute() 100 assertTrue(done.await(LONG_DELAY_MS, MILLISECONDS)); in testExecute() 109 final CountDownLatch done = new CountDownLatch(1); in testGetActiveCount() local 114 try (PoolCleaner cleaner = cleaner(p, done)) { in testGetActiveCount() argument 121 await(done); in testGetActiveCount() 336 final CountDownLatch done = new CountDownLatch(1); in testGetLargestPoolSize() local 341 try (PoolCleaner cleaner = cleaner(p, done)) { in testGetLargestPoolSize() argument 348 await(done); in testGetLargestPoolSize() 380 final CountDownLatch done = new CountDownLatch(1); in testGetPoolSize() local [all …]
|
D | ThreadPoolExecutorSubclassTest.java | 57 boolean done; field in ThreadPoolExecutorSubclassTest.CustomTask 72 lock.lock(); try { return done; } finally { lock.unlock() ; } in isDone() 80 if (!done) { in cancel() 82 done = true; in cancel() 94 if (done) in run() 109 if (!done) { in run() 112 done = true; in run() 122 while (!done) in get() 137 while (!done) { in get() 243 final CountDownLatch done = new CountDownLatch(1); in testExecute() local [all …]
|
D | ScheduledExecutorTest.java | 55 final CountDownLatch done = new CountDownLatch(1); in testExecute() local 57 public void realRun() { done.countDown(); }}; in testExecute() 59 assertTrue(done.await(LONG_DELAY_MS, MILLISECONDS)); in testExecute() 70 final CountDownLatch done = new CountDownLatch(1); in testSchedule1() local 73 done.countDown(); in testSchedule1() 80 assertTrue(done.await(0L, MILLISECONDS)); in testSchedule1() 91 final CountDownLatch done = new CountDownLatch(1); in testSchedule3() local 94 done.countDown(); in testSchedule3() 98 await(done); in testSchedule3() 111 final CountDownLatch done = new CountDownLatch(1); in testSchedule4() local [all …]
|
D | ScheduledExecutorSubclassTest.java | 112 final CountDownLatch done = new CountDownLatch(1); in testExecute() local 114 public void realRun() { done.countDown(); }}; in testExecute() 116 await(done); in testExecute() 124 final CountDownLatch done = new CountDownLatch(1); in testSchedule1() local 126 try (PoolCleaner cleaner = cleaner(p, done)) { in testSchedule1() argument 130 done.countDown(); in testSchedule1() 147 final CountDownLatch done = new CountDownLatch(1); in testSchedule3() local 150 done.countDown(); in testSchedule3() 154 await(done); in testSchedule3() 167 final CountDownLatch done = new CountDownLatch(1); in testSchedule4() local [all …]
|
D | ExecutorCompletionServiceTest.java | 162 final AtomicBoolean done = new AtomicBoolean(false); in testNewTaskForCallable() local 165 protected void done() { done.set(true); } in testNewTaskForCallable() method in ExecutorCompletionServiceTest.MyCallableFuture 184 assertTrue("completed task must have set done", done.get()); in testNewTaskForCallable() 193 final AtomicBoolean done = new AtomicBoolean(false); in testNewTaskForRunnable() local 196 protected void done() { done.set(true); } in testNewTaskForRunnable() method in ExecutorCompletionServiceTest.MyRunnableFuture 215 assertTrue("completed task must have set done", done.get()); in testNewTaskForRunnable()
|
D | Collection8Test.java | 79 final AtomicBoolean done = new AtomicBoolean(false); in testForEachConcurrentStressTest() local 83 try (PoolCleaner cleaner = cleaner(pool, done)) { in testForEachConcurrentStressTest() argument 87 while (!done.get()) in testForEachConcurrentStressTest() 91 while (!done.get()) { in testForEachConcurrentStressTest()
|
D | ForkJoinPoolTest.java | 221 final CountDownLatch done = new CountDownLatch(1); in testGetPoolSize() local 230 done.await(); in testGetPoolSize() 236 done.countDown(); in testGetPoolSize() 387 final CountDownLatch done = new CountDownLatch(1); 390 ForkJoinTask a = p.submit(awaiter(done)); 391 ForkJoinTask b = p.submit(awaiter(done)); 392 ForkJoinTask c = p.submit(awaiter(done)); 396 done.countDown(); 404 final CountDownLatch done = new CountDownLatch(1); 407 ForkJoinTask a = p.submit(awaiter(done)); [all …]
|
D | JSR166TestCase.java | 1642 private volatile boolean done = false; 1643 public boolean isDone() { return done; } 1647 done = true; 1654 public volatile boolean done = false; 1658 done = true; 1664 public volatile boolean done = false; 1668 done = true; 1674 public volatile boolean done = false; 1678 done = true; 1684 public volatile boolean done = false; [all …]
|
D | ExecutorsTest.java | 309 final CountDownLatch done = new CountDownLatch(1); in testDefaultThreadFactory() local 327 done.countDown(); in testDefaultThreadFactory() 332 await(done); in testDefaultThreadFactory() 342 final CountDownLatch done = new CountDownLatch(1); in testPrivilegedThreadFactory() local 364 done.countDown(); in testPrivilegedThreadFactory() 369 await(done); in testPrivilegedThreadFactory()
|
D | AtomicIntegerArrayTest.java | 288 boolean done = true; in realRun() 293 done = false; in realRun() 298 if (done) in realRun()
|
D | AtomicLongArrayTest.java | 287 boolean done = true; in realRun() 292 done = false; in realRun() 297 if (done) in realRun()
|
D | CyclicBarrierTest.java | 306 final AtomicBoolean done = new AtomicBoolean(); in testReset_Leakage() local 309 while (!done.get()) { in testReset_Leakage() 325 done.set(true); in testReset_Leakage()
|
/libcore/ojluni/src/main/java/javax/crypto/ |
D | ExemptionMechanism.java | 64 private boolean done = false; field in ExemptionMechanism 260 if (done && (key != null)) { in isCryptoAllowed() 316 done = false; in init() 348 done = false; in init() 380 done = false; in init() 405 done = true; in genExemptionBlob() 438 done = true; in genExemptionBlob() 474 done = true; in genExemptionBlob()
|
D | CipherInputStream.java | 84 private boolean done = false; field in CipherInputStream 116 if (done) return -1; in getMoreData() 125 done = true; in getMoreData() 329 if (!done) { in close()
|
/libcore/ojluni/src/main/java/java/util/concurrent/atomic/ |
D | Striped64.java | 231 done: for (;;) { in longAccumulate() 244 break done; in longAccumulate() local 281 break done; in longAccumulate() local 290 break done; in longAccumulate() local 315 done: for (;;) { in doubleAccumulate() 328 break done; in doubleAccumulate() local 364 break done; in doubleAccumulate() local 372 break done; in doubleAccumulate() local
|
/libcore/ojluni/src/main/java/sun/util/locale/ |
D | StringTokenIterator.java | 41 private boolean done; field in StringTokenIterator 71 return done; in isDone() 82 done = true; in next() 98 done = false; in setStart()
|
/libcore/luni/src/test/java/libcore/java/lang/ |
D | ThreadTest.java | 129 assertTrue("Threads already finished", !t1.done && !t2.done); in testThreadWakeup() 135 assertTrue("Threads did not finish", t1.done && t2.done); in testThreadWakeup() 492 public boolean done; field in WakeupTestThread 495 done = false; in run() 503 done = true; in run()
|
D | SystemTest.java | 135 final AtomicBoolean done = new AtomicBoolean(); in testArrayCopyConcurrentModification() local 144 while (!done.get()) { in testArrayCopyConcurrentModification() 159 done.set(true); in testArrayCopyConcurrentModification()
|
/libcore/ojluni/src/main/java/sun/nio/fs/ |
D | UnixCopyFile.java | 157 boolean done = false; in copyDirectory() 207 done = true; in copyDirectory() 211 if (!done) { in copyDirectory() 342 boolean done = false; in copySpecial() 363 done = true; in copySpecial() 365 if (!done) { in copySpecial()
|
/libcore/dom/src/test/java/org/w3c/domts/level2/core/ |
D | createElementNS06.java | 65 boolean done; in runTest()
|
D | createElementNS03.java | 72 boolean done; in runTest()
|
/libcore/luni/src/test/java/libcore/dalvik/system/ |
D | InMemoryDexClassLoaderTest.java | 109 int done = 0; in readFileToByteBufferDirect() local 110 while (done != file.length()) { in readFileToByteBufferDirect() 111 done += raf.getChannel().read(buffer); in readFileToByteBufferDirect()
|
/libcore/ojluni/annotations/ |
D | README | 19 …on/stubsDir/${FILE} libcore/ojluni/annotations/sdk/nullability/${FILE/%.java/.annotated.java}; done 34 …oid_common/stubsDir/${FILE} libcore/ojluni/annotations/mmodule/${FILE/%.java/.annotated.java}; done
|
/libcore/ojluni/src/main/java/java/util/concurrent/ |
D | FutureTask.java | 219 protected void done() { } in done() method in FutureTask 383 done(); in finishCompletion()
|