/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/jsr166-tests/src/test/java/jsr166/ |
D | ThreadPoolExecutorTest.java | 64 final CountDownLatch done = new CountDownLatch(1); in testExecute() local 67 done.countDown(); in testExecute() 71 assertTrue(done.await(SMALL_DELAY_MS, MILLISECONDS)); in testExecute() 87 final CountDownLatch done = new CountDownLatch(1); in testGetActiveCount() local 94 done.await(); in testGetActiveCount() 99 done.countDown(); in testGetActiveCount() 301 final CountDownLatch done = new CountDownLatch(1); in testGetLargestPoolSize() local 308 done.await(); in testGetLargestPoolSize() 314 done.countDown(); in testGetLargestPoolSize() 343 final CountDownLatch done = new CountDownLatch(1); in testGetPoolSize() local [all …]
|
D | ScheduledExecutorTest.java | 24 final CountDownLatch done = new CountDownLatch(1); in testExecute() local 27 done.countDown(); in testExecute() 31 assertTrue(done.await(SMALL_DELAY_MS, MILLISECONDS)); in testExecute() 43 final CountDownLatch done = new CountDownLatch(1); in testSchedule1() local 47 done.countDown(); in testSchedule1() 54 assertTrue(done.await(0L, MILLISECONDS)); in testSchedule1() 66 final CountDownLatch done = new CountDownLatch(1); in testSchedule3() local 70 done.countDown(); in testSchedule3() 74 await(done); in testSchedule3() 88 final CountDownLatch done = new CountDownLatch(1); in testSchedule4() local [all …]
|
D | ScheduledExecutorSubclassTest.java | 76 final CountDownLatch done = new CountDownLatch(1); in testExecute() local 79 done.countDown(); in testExecute() 83 assertTrue(done.await(SMALL_DELAY_MS, MILLISECONDS)); in testExecute() 95 final CountDownLatch done = new CountDownLatch(1); in testSchedule1() local 99 done.countDown(); in testSchedule1() 106 assertTrue(done.await(0L, MILLISECONDS)); in testSchedule1() 118 final CountDownLatch done = new CountDownLatch(1); in testSchedule3() local 122 done.countDown(); in testSchedule3() 126 await(done); in testSchedule3() 140 final CountDownLatch done = new CountDownLatch(1); in testSchedule4() local [all …]
|
D | ThreadPoolExecutorSubclassTest.java | 24 boolean done; field in ThreadPoolExecutorSubclassTest.CustomTask 39 lock.lock(); try { return done; } finally { lock.unlock() ; } in isDone() 47 if (!done) { in cancel() 49 done = true; in cancel() 61 if (done) in run() 78 done = true; in run() 87 while (!done) in get() 101 if (done) break; in get() 204 final CountDownLatch done = new CountDownLatch(1); in testExecute() local 207 done.countDown(); in testExecute() [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 183 assertTrue("completed task must have set done", done.get()); in testNewTaskForCallable() 194 final AtomicBoolean done = new AtomicBoolean(false); in testNewTaskForRunnable() local 197 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 | JSR166TestCase.java | 928 private volatile boolean done = false; 929 public boolean isDone() { return done; } 933 done = true; 940 public volatile boolean done = false; 944 done = true; 950 public volatile boolean done = false; 954 done = true; 960 public volatile boolean done = false; 964 done = true; 970 public volatile boolean done = false; [all …]
|
D | ForkJoinPoolTest.java | 370 final CountDownLatch done = new CountDownLatch(1); in testPollSubmission() local 373 ForkJoinTask a = p.submit(awaiter(done)); in testPollSubmission() 374 ForkJoinTask b = p.submit(awaiter(done)); in testPollSubmission() 375 ForkJoinTask c = p.submit(awaiter(done)); in testPollSubmission() 380 done.countDown(); in testPollSubmission() 389 final CountDownLatch done = new CountDownLatch(1); in testDrainTasksTo() local 392 ForkJoinTask a = p.submit(awaiter(done)); in testDrainTasksTo() 393 ForkJoinTask b = p.submit(awaiter(done)); in testDrainTasksTo() 394 ForkJoinTask c = p.submit(awaiter(done)); in testDrainTasksTo() 403 done.countDown(); in testDrainTasksTo() [all …]
|
D | ExecutorsTest.java | 287 final CountDownLatch done = new CountDownLatch(1); in testDefaultThreadFactory() local 305 done.countDown(); in testDefaultThreadFactory() 310 await(done); in testDefaultThreadFactory() 326 final CountDownLatch done = new CountDownLatch(1); in testPrivilegedThreadFactory() local 347 done.countDown(); in testPrivilegedThreadFactory() 351 await(done); in testPrivilegedThreadFactory()
|
D | AtomicLongArrayTest.java | 278 boolean done = true; in realRun() 283 done = false; in realRun() 288 if (done) in realRun()
|
D | AtomicIntegerArrayTest.java | 278 boolean done = true; in realRun() 283 done = false; in realRun() 288 if (done) in realRun()
|
D | CyclicBarrierTest.java | 295 final AtomicBoolean done = new AtomicBoolean(); in testReset_Leakage() local 298 while (!done.get()) { in testReset_Leakage() 314 done.set(true); in testReset_Leakage()
|
/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 | 202 boolean done = false; in invokeAll() 219 done = true; in invokeAll() 222 if (!done) in invokeAll() 235 boolean done = false; in invokeAll() 267 done = true; in invokeAll() 270 if (!done) in invokeAll()
|
D | ExecutorCompletionService.java | 91 protected void done() { completionQueue.add(task); } in done() method in ExecutorCompletionService.QueueingFuture
|
D | FutureTask.java | 189 protected void done() { } in done() method in FutureTask 355 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()
|