/libcore/jsr166-tests/src/test/java/jsr166/ |
D | ScheduledExecutorTest.java | 48 final CountDownLatch done = new CountDownLatch(1); in testExecute() local 51 done.countDown(); in testExecute() 55 assertTrue(done.await(SMALL_DELAY_MS, MILLISECONDS)); in testExecute() 67 final CountDownLatch done = new CountDownLatch(1); in testSchedule1() local 71 done.countDown(); in testSchedule1() 78 assertTrue(done.await(0L, MILLISECONDS)); in testSchedule1() 90 final CountDownLatch done = new CountDownLatch(1); in testSchedule3() local 94 done.countDown(); in testSchedule3() 98 await(done); in testSchedule3() 112 final CountDownLatch done = new CountDownLatch(1); in testSchedule4() local [all …]
|
D | ScheduledExecutorSubclassTest.java | 105 final CountDownLatch done = new CountDownLatch(1); in testExecute() local 108 done.countDown(); in testExecute() 112 assertTrue(done.await(SMALL_DELAY_MS, MILLISECONDS)); in testExecute() 124 final CountDownLatch done = new CountDownLatch(1); in testSchedule1() local 128 done.countDown(); in testSchedule1() 135 assertTrue(done.await(0L, MILLISECONDS)); in testSchedule1() 147 final CountDownLatch done = new CountDownLatch(1); in testSchedule3() local 151 done.countDown(); in testSchedule3() 155 await(done); in testSchedule3() 169 final CountDownLatch done = new CountDownLatch(1); in testSchedule4() local [all …]
|
D | ThreadPoolExecutorTest.java | 92 final CountDownLatch done = new CountDownLatch(1); in testExecute() local 95 done.countDown(); in testExecute() 99 assertTrue(done.await(SMALL_DELAY_MS, MILLISECONDS)); in testExecute() 115 final CountDownLatch done = new CountDownLatch(1); in testGetActiveCount() local 122 done.await(); in testGetActiveCount() 127 done.countDown(); in testGetActiveCount() 329 final CountDownLatch done = new CountDownLatch(1); in testGetLargestPoolSize() local 336 done.await(); in testGetLargestPoolSize() 342 done.countDown(); in testGetLargestPoolSize() 371 final CountDownLatch done = new CountDownLatch(1); in testGetPoolSize() local [all …]
|
D | ThreadPoolExecutorSubclassTest.java | 54 boolean done; field in ThreadPoolExecutorSubclassTest.CustomTask 69 lock.lock(); try { return done; } finally { lock.unlock() ; } in isDone() 77 if (!done) { in cancel() 79 done = true; in cancel() 91 if (done) in run() 108 done = true; in run() 117 while (!done) in get() 131 if (done) break; in get() 234 final CountDownLatch done = new CountDownLatch(1); in testExecute() local 237 done.countDown(); in testExecute() [all …]
|
D | ExecutorCompletionServiceTest.java | 172 final AtomicBoolean done = new AtomicBoolean(false); in testNewTaskForCallable() local 175 protected void done() { done.set(true); } in testNewTaskForCallable() method in ExecutorCompletionServiceTest.MyCallableFuture 193 assertTrue("completed task must have set done", done.get()); in testNewTaskForCallable() 204 final AtomicBoolean done = new AtomicBoolean(false); in testNewTaskForRunnable() local 207 protected void done() { done.set(true); } in testNewTaskForRunnable() method in ExecutorCompletionServiceTest.MyRunnableFuture 225 assertTrue("completed task must have set done", done.get()); in testNewTaskForRunnable()
|
D | JSR166TestCase.java | 986 private volatile boolean done = false; 987 public boolean isDone() { return done; } 991 done = true; 998 public volatile boolean done = false; 1002 done = true; 1008 public volatile boolean done = false; 1012 done = true; 1018 public volatile boolean done = false; 1022 done = true; 1028 public volatile boolean done = false; [all …]
|
D | ForkJoinPoolTest.java | 378 final CountDownLatch done = new CountDownLatch(1); in testPollSubmission() local 381 ForkJoinTask a = p.submit(awaiter(done)); in testPollSubmission() 382 ForkJoinTask b = p.submit(awaiter(done)); in testPollSubmission() 383 ForkJoinTask c = p.submit(awaiter(done)); in testPollSubmission() 388 done.countDown(); in testPollSubmission() 397 final CountDownLatch done = new CountDownLatch(1); in testDrainTasksTo() local 400 ForkJoinTask a = p.submit(awaiter(done)); in testDrainTasksTo() 401 ForkJoinTask b = p.submit(awaiter(done)); in testDrainTasksTo() 402 ForkJoinTask c = p.submit(awaiter(done)); in testDrainTasksTo() 411 done.countDown(); in testDrainTasksTo() [all …]
|
D | ExecutorsTest.java | 309 final CountDownLatch done = new CountDownLatch(1); in testDefaultThreadFactory() local 327 done.countDown(); in testDefaultThreadFactory() 332 await(done); in testDefaultThreadFactory() 348 final CountDownLatch done = new CountDownLatch(1); in testPrivilegedThreadFactory() local 370 done.countDown(); in testPrivilegedThreadFactory() 374 await(done); in testPrivilegedThreadFactory()
|
D | AtomicIntegerArrayTest.java | 287 boolean done = true; in realRun() 292 done = false; in realRun() 297 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/luni/src/test/java/libcore/java/lang/ |
D | ThreadTest.java | 110 assertTrue("Threads already finished", !t1.done && !t2.done); in testThreadWakeup() 116 assertTrue("Threads did not finish", t1.done && t2.done); in testThreadWakeup() 181 public boolean done; field in WakeupTestThread 184 done = false; in run() 192 done = true; in run()
|
D | SystemTest.java | 125 final AtomicBoolean done = new AtomicBoolean(); in testArrayCopyConcurrentModification() local 134 while (!done.get()) { in testArrayCopyConcurrentModification() 149 done.set(true); in testArrayCopyConcurrentModification()
|
/libcore/luni/src/main/java/java/util/zip/ |
D | DeflaterOutputStream.java | 46 boolean done = false; field in DeflaterOutputStream 149 if (done) { in finish() 157 done = true; in finish() 171 if (done) { in write() 194 if (syncFlush && !done) { in flush()
|
/libcore/luni/src/main/java/java/util/jar/ |
D | JarFile.java | 64 private boolean done = false; field in JarFile.JarFileInputStream 75 if (done) { in read() 87 done = true; in read() 92 done = true; in read() 100 if (done) { in read() 116 done = true; in read() 121 done = true; in read() 129 if (done) { in available()
|
/libcore/luni/src/main/java/java/util/concurrent/ |
D | AbstractExecutorService.java | 203 boolean done = false; in invokeAll() 220 done = true; in invokeAll() 223 if (!done) in invokeAll() 236 boolean done = false; in invokeAll() 268 done = true; in invokeAll() 271 if (!done) in invokeAll()
|
D | ExecutorCompletionService.java | 91 protected void done() { completionQueue.add(task); } in done() method in ExecutorCompletionService.QueueingFuture
|
D | FutureTask.java | 190 protected void done() { } in done() method in FutureTask 354 done(); in finishCompletion()
|
/libcore/luni/src/main/java/java/net/ |
D | NetworkInterface.java | 305 boolean[] done = new boolean[interfaces.length]; in getNetworkInterfacesList() 313 done[i] = true; in getNetworkInterfacesList() 320 if (done[counter]) { in getNetworkInterfacesList() 326 if (done[counter2]) { in getNetworkInterfacesList() 333 done[counter2] = true; in getNetworkInterfacesList() 337 done[counter] = true; in getNetworkInterfacesList()
|
/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/main/java/java/io/ |
D | PipedOutputStream.java | 68 stream.done(); in close()
|
D | PipedWriter.java | 68 reader.done(); in close()
|
/libcore/luni/src/test/java/libcore/java/util/concurrent/ |
D | CopyOnWriteArrayListTest.java | 177 final CountDownLatch done = new CountDownLatch(1); in testAddAllIsAtomic() local 182 while (done.getCount() > 0) { in testAddAllIsAtomic() 198 done.countDown(); in testAddAllIsAtomic()
|
/libcore/harmony-tests/src/test/java/org/apache/harmony/tests/java/lang/ |
D | ThreadTest.java | 562 public volatile boolean done = false; in test_isInterrupted() field in ThreadTest.SpinThread 567 while (!done) in test_isInterrupted() 582 spin.done = true; in test_isInterrupted() 585 spin.done = true; in test_isInterrupted()
|