Home
last modified time | relevance | path

Searched refs:done (Results 1 – 25 of 68) sorted by relevance

123

/libcore/luni/src/test/java/libcore/java/nio/channels/
DFutureLikeCompletionHandler.java24 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/
DThreadPoolExecutorTest.java96 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 …]
DThreadPoolExecutorSubclassTest.java57 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 …]
DScheduledExecutorSubclassTest.java112 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 …]
DScheduledExecutorTest.java55 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 …]
DExecutorCompletionServiceTest.java162 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()
DCollection8Test.java79 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()
DForkJoinPoolTest.java221 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 …]
DJSR166TestCase.java1642 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 …]
DExecutorsTest.java309 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()
/libcore/ojluni/src/test/java/util/concurrent/tck/
DThreadPoolExecutorTest.java118 final CountDownLatch done = new CountDownLatch(1); in testExecute() local
120 public void realRun() { done.countDown(); }}; in testExecute()
122 assertTrue(done.await(LONG_DELAY_MS, MILLISECONDS)); in testExecute()
131 final CountDownLatch done = new CountDownLatch(1); in testGetActiveCount() local
136 try (PoolCleaner cleaner = cleaner(p, done)) { in testGetActiveCount() argument
143 await(done); in testGetActiveCount()
358 final CountDownLatch done = new CountDownLatch(1); in testGetLargestPoolSize() local
363 try (PoolCleaner cleaner = cleaner(p, done)) { in testGetLargestPoolSize() argument
370 await(done); in testGetLargestPoolSize()
402 final CountDownLatch done = new CountDownLatch(1); in testGetPoolSize() local
[all …]
DThreadPoolExecutorSubclassTest.java79 boolean done; field in ThreadPoolExecutorSubclassTest.CustomTask
94 lock.lock(); try { return done; } finally { lock.unlock() ; } in isDone()
102 if (!done) { in cancel()
104 done = true; in cancel()
116 if (done) in run()
131 if (!done) { in run()
134 done = true; in run()
144 while (!done) in get()
159 while (!done) { in get()
265 final CountDownLatch done = new CountDownLatch(1); in testExecute() local
[all …]
DScheduledExecutorSubclassTest.java136 final CountDownLatch done = new CountDownLatch(1); in testExecute() local
138 public void realRun() { done.countDown(); }}; in testExecute()
140 await(done); in testExecute()
148 final CountDownLatch done = new CountDownLatch(1); in testSchedule1() local
150 try (PoolCleaner cleaner = cleaner(p, done)) { in testSchedule1() argument
154 done.countDown(); in testSchedule1()
171 final CountDownLatch done = new CountDownLatch(1); in testSchedule3() local
174 done.countDown(); in testSchedule3()
178 await(done); in testSchedule3()
191 final CountDownLatch done = new CountDownLatch(1); in testSchedule4() local
[all …]
DScheduledExecutorTest.java79 final CountDownLatch done = new CountDownLatch(1); in testExecute() local
81 public void realRun() { done.countDown(); }}; in testExecute()
83 assertTrue(done.await(LONG_DELAY_MS, MILLISECONDS)); in testExecute()
94 final CountDownLatch done = new CountDownLatch(1); in testSchedule1() local
97 done.countDown(); in testSchedule1()
104 assertTrue(done.await(0L, MILLISECONDS)); in testSchedule1()
115 final CountDownLatch done = new CountDownLatch(1); in testSchedule3() local
118 done.countDown(); in testSchedule3()
122 await(done); in testSchedule3()
135 final CountDownLatch done = new CountDownLatch(1); in testSchedule4() local
[all …]
DExecutorCompletionServiceTest.java223 final AtomicBoolean done = new AtomicBoolean(false); in testNewTaskForCallable() local
226 @Override protected void done() { done.set(true); } in testNewTaskForCallable() method in ExecutorCompletionServiceTest.MyCallableFuture
244 assertTrue("completed task must have set done", done.get()); in testNewTaskForCallable()
253 final AtomicBoolean done = new AtomicBoolean(false); in testNewTaskForRunnable() local
256 @Override protected void done() { done.set(true); } in testNewTaskForRunnable() method in ExecutorCompletionServiceTest.MyRunnableFuture
274 assertTrue("completed task must have set done", done.get()); in testNewTaskForRunnable()
DForkJoinPoolTest.java239 final CountDownLatch done = new CountDownLatch(1); in testGetPoolSize() local
248 done.await(); in testGetPoolSize()
254 done.countDown(); in testGetPoolSize()
405 final CountDownLatch done = new CountDownLatch(1);
408 ForkJoinTask a = p.submit(awaiter(done));
409 ForkJoinTask b = p.submit(awaiter(done));
410 ForkJoinTask c = p.submit(awaiter(done));
414 done.countDown();
422 final CountDownLatch done = new CountDownLatch(1);
425 ForkJoinTask a = p.submit(awaiter(done));
[all …]
/libcore/ojluni/src/main/java/javax/crypto/
DExemptionMechanism.java64 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()
DCipherInputStream.java84 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/sun/util/locale/
DStringTokenIterator.java41 private boolean done; field in StringTokenIterator
71 return done; in isDone()
82 done = true; in next()
98 done = false; in setStart()
/libcore/ojluni/src/test/java/util/Properties/
DConcurrentLoadAndStoreXML.java45 static volatile boolean done; field in ConcurrentLoadAndStoreXML
59 while (!done) { in call()
103 done = true; in main()
110 done = true; in main()
/libcore/luni/src/test/java/libcore/java/lang/
DThreadTest.java147 assertTrue("Threads already finished", !t1.done && !t2.done); in threadWakeup()
153 assertTrue("Threads did not finish", t1.done && t2.done); in threadWakeup()
578 public volatile boolean done; field in WakeupTestThread
581 done = false; in run()
589 done = true; in run()
599 assertFalse(t.done); in onSpinWait()
602 assertTrue(t.done); in onSpinWait()
607 public volatile boolean done = false; field in SpinWaitThread
610 done = false; in run()
614 done = true; in run()
/libcore/ojluni/src/test/java/util/Timer/
DDelayOverflow.java76 final CountDownLatch done = new CountDownLatch(1); in test() local
84 done.countDown(); in test()
88 done.await(); in test()
/libcore/ojluni/src/test/java/net/Socks/
DSocksServer.java63 private volatile boolean done = false; field in SocksServer
159 boolean done = false; in purge()
162 while(!done && i != -1) { in purge()
166 done = true; in purge()
509 done = true; in terminate()
515 while (!done) { in run()
/libcore/ojluni/src/main/java/sun/nio/fs/
DUnixCopyFile.java157 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/ojluni/src/test/java/lang/invoke/
DPermuteArgsTest.java236 HashSet<String> done = new HashSet<>(); in testPermutations() local
252 testPermutations(mh, perm, start, end, done); in testPermutations()
271 Set<String> done) throws Throwable { in testPermutations() argument
274 testRotations(mh, perm, start, end, done); in testPermutations()
289 testPermutations(mh, perm, start2, end2, done); in testPermutations()
296 Set<String> done) throws Throwable { in testRotations() argument
299 if (done.add(Arrays.toString(perm))) in testRotations()

123